Uses of Interface
org.apache.qpid.protonj2.engine.TransactionManager
Packages that use TransactionManager
-
Uses of TransactionManager in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return TransactionManagerModifier 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
.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type TransactionManagerModifier 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
Classes in org.apache.qpid.protonj2.engine.impl that implement TransactionManagerModifier and TypeClassDescriptionfinal class
TransactionManager
implementation that implements the abstraction around a receiver link that responds to requests toDeclare
and toDischarge
AMQPTransaction
instance.Methods in org.apache.qpid.protonj2.engine.impl that return TransactionManagerModifier 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) Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type TransactionManagerModifier 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)