Uses of Interface
org.apache.qpid.protonj2.engine.TransactionManager
-
Uses of TransactionManager in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionTransactionManager.addCredit
(int additionalCredit) Adds the given amount of credit for theTransactionManager
which allows theTransactionController
to sendDeclare
andDischarge
requests to this manager.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.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.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.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.TransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionManager
is locally closed.TransactionManager.setCoordinator
(Coordinator coordinator) Sets theCoordinator
target to assign to the local end of thisTransactionManager
.Sets theSource
to assign to the local end of thisTransactionManager
.Modifier and TypeMethodDescriptiondefault 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.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.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.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.TransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionManager
is locally closed.Connection.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a transaction coordination link.Session.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a transaction coordination link. -
Uses of TransactionManager in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionfinal class
TransactionManager
implementation that implements the abstraction around a receiver link that responds to requests toDeclare
and toDischarge
AMQPTransaction
instance.Modifier and TypeMethodDescriptionProtonTransactionManager.addCredit
(int additional) ProtonTransactionManager.close()
ProtonTransactionManager.declared
(Transaction<TransactionManager> transaction, Binary txnId) ProtonTransactionManager.declareFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) ProtonTransactionManager.declareHandler
(EventHandler<Transaction<TransactionManager>> declaredEventHandler) ProtonTransactionManager.discharged
(Transaction<TransactionManager> transaction) ProtonTransactionManager.dischargeFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) ProtonTransactionManager.dischargeHandler
(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) ProtonTransactionManager.open()
ProtonTransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) ProtonTransactionManager.setCondition
(ErrorCondition condition) ProtonTransactionManager.setCoordinator
(Coordinator coordinator) ProtonTransactionManager.setDesiredCapabilities
(Symbol... desiredCapabilities) ProtonTransactionManager.setOfferedCapabilities
(Symbol... offeredCapabilities) ProtonTransactionManager.setProperties
(Map<Symbol, Object> properties) Modifier and TypeMethodDescriptionProtonTransactionManager.declared
(Transaction<TransactionManager> transaction, Binary txnId) ProtonTransactionManager.declareFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) ProtonTransactionManager.declareHandler
(EventHandler<Transaction<TransactionManager>> declaredEventHandler) ProtonTransactionManager.discharged
(Transaction<TransactionManager> transaction) ProtonTransactionManager.dischargeFailed
(Transaction<TransactionManager> transaction, ErrorCondition condition) ProtonTransactionManager.dischargeHandler
(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) ProtonTransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) ProtonConnection.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) ProtonSession.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler)