Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #750

This commit is contained in:
Clebert Suconic 2016-09-06 09:36:50 -04:00
parent b13d1b0d89 930d814daf
commit bfc2095b61
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/ProtonTransactionHandler.java
View File

@ -20,6 +20,7 @@ import io.netty.buffer.ByteBuf;
import io.netty.buffer.PooledByteBufAllocator;
import org.apache.qpid.proton.amqp.Binary;
import org.apache.qpid.proton.amqp.Symbol;
import org.apache.qpid.proton.amqp.messaging.Accepted;
import org.apache.qpid.proton.amqp.messaging.AmqpValue;
import org.apache.qpid.proton.amqp.messaging.Rejected;
import org.apache.qpid.proton.amqp.transaction.Declare;
@ -82,6 +83,7 @@ public class ProtonTransactionHandler implements ProtonDeliveryHandler {
if (discharge.getFail()) {
try {
sessionSPI.rollbackCurrentTX(true);
delivery.disposition(new Accepted());
}
catch (Exception e) {
throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.errorRollingbackCoordinator(e.getMessage());
@ -90,6 +92,7 @@ public class ProtonTransactionHandler implements ProtonDeliveryHandler {
else {
try {
sessionSPI.commitCurrentTX();
delivery.disposition(new Accepted());
}
catch (ActiveMQAMQPException amqpE) {
throw amqpE;
@ -99,7 +102,6 @@ public class ProtonTransactionHandler implements ProtonDeliveryHandler {
}
}
}
}
catch (ActiveMQAMQPException amqpE) {
delivery.disposition(createRejected(amqpE.getAmqpError(), amqpE.getMessage()));