Class ProtonTransactionHandler
java.lang.Object
org.apache.activemq.artemis.protocol.amqp.proton.transaction.ProtonTransactionHandler
- All Implemented Interfaces:
ProtonDeliveryHandler
handles an amqp Coordinator to deal with transaction boundaries etc
-
Constructor Summary
ConstructorsConstructorDescriptionProtonTransactionHandler(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose(boolean linkRemoteClose) voidclose(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) org.apache.activemq.artemis.core.transaction.TransactionvoidonFlow(int credits, boolean drain) voidonMessage(org.apache.qpid.proton.engine.Delivery delivery)
-
Constructor Details
-
ProtonTransactionHandler
-
-
Method Details
-
onMessage
- Specified by:
onMessagein interfaceProtonDeliveryHandler- Throws:
ActiveMQAMQPException
-
onFlow
public void onFlow(int credits, boolean drain) - Specified by:
onFlowin interfaceProtonDeliveryHandler
-
close
- Specified by:
closein interfaceProtonDeliveryHandler- Throws:
ActiveMQAMQPException
-
close
public void close(org.apache.qpid.proton.amqp.transport.ErrorCondition condition) throws ActiveMQAMQPException - Specified by:
closein interfaceProtonDeliveryHandler- Throws:
ActiveMQAMQPException
-
getCurrentTransaction
public org.apache.activemq.artemis.core.transaction.Transaction getCurrentTransaction()
-