Uses of Interface
org.apache.qpid.protonj2.engine.Transaction
-
Uses of Transaction in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionTransactionController.declare()
Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.TransactionController.newTransaction()
Creates a newTransaction
instances that is returned in theTransactionState.IDLE
state which can be populated with application specific attachments or assigned a linked resource prior to calling theModifier and TypeMethodDescriptionTransactionController.transactions()
Returns a list ofTransaction
objects that are active within thisTransactionController
which have not reached a terminal state meaning they have not been successfully discharged and have not failed in either theDeclare
phase or theDischarge
phase.Modifier and TypeMethodDescriptionTransactionController.declare
(Transaction<TransactionController> transaction) Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.default TransactionManager
TransactionManager.declared
(Transaction<TransactionManager> transaction, byte[] txnId) Respond to a previousDeclare
request from the remoteTransactionController
indicating that the requested transaction has been successfully declared and that deliveries can now be enlisted in that transaction.TransactionManager.declared
(Transaction<TransactionManager> transaction, Binary txnId) Respond to a previousDeclare
request from the remoteTransactionController
indicating that the requested transaction has been successfully declared and that deliveries can now be enlisted in that transaction.TransactionManager.declareFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) Respond to a previousDeclare
request from the remoteTransactionController
indicating that the requested transaction declaration has failed and is not active.TransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) Request that the remoteTransactionManager
discharge the given transaction and with the specified failure state (true for failed).TransactionManager.discharged
(Transaction<TransactionManager> transaction) Respond to a previousDischarge
request from the remoteTransactionController
indicating that the discharge completed on the transaction identified by given transaction Id has now been retired.TransactionManager.dischargeFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) Respond to a previousDischarge
request from the remoteTransactionController
indicating that the discharge resulted in an error and the transaction must be considered rolled back.Modifier and TypeMethodDescriptionTransactionController.declaredHandler
(EventHandler<Transaction<TransactionController>> declaredEventHandler) Called when theTransactionManager
end of the link has responded to a previousDeclare
request and the transaction can now be used to enroll deliveries into the active transaction.TransactionController.declareFailureHandler
(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) Called when theTransactionManager
end of the link responds to aTransaction
declaration with anRejected
outcome indicating that the transaction could not be successfully declared.TransactionManager.declareHandler
(EventHandler<Transaction<TransactionManager>> declaredEventHandler) Called when theTransactionController
end of the link has requested a new transaction be declared using the information provided in the givenDeclare
instance.TransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManager
end of the link has responded to a previousTransactionController.discharge(Transaction, boolean)
request and the transaction has been retired.TransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) Called when theTransactionManager
end of the link has responded to a previousTransactionController.discharge(Transaction, boolean)
request and the transaction discharge failed for some reason.TransactionManager.dischargeHandler
(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) Called when theTransactionController
end of the link has requested a current transaction be discharged using the information provided in the givenDischarge
instance. -
Uses of Transaction in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionclass
ProtonTransaction<E extends Endpoint<?>>
BaseTransaction
implementation that provides the basic functionality needed to manage theTransaction
that it represents.Modifier and TypeMethodDescriptionProtonTransactionController.declare
(Transaction<TransactionController> transaction) ProtonTransactionManager.declared
(Transaction<TransactionManager> transaction, Binary txnId) ProtonTransactionManager.declareFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) ProtonTransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) ProtonTransactionManager.discharged
(Transaction<TransactionManager> transaction) ProtonTransactionManager.dischargeFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) Modifier and TypeMethodDescriptionProtonTransactionController.declaredHandler
(EventHandler<Transaction<TransactionController>> declaredEventHandler) ProtonTransactionController.declareFailureHandler
(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) ProtonTransactionManager.declareHandler
(EventHandler<Transaction<TransactionManager>> declaredEventHandler) ProtonTransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) ProtonTransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) ProtonTransactionManager.dischargeHandler
(EventHandler<Transaction<TransactionManager>> dischargeEventHandler)