Uses of Interface
org.apache.qpid.protonj2.engine.TransactionController
-
Uses of TransactionController in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionTransactionController.addCapacityAvailableHandler
(EventHandler<TransactionController> handler) Allows the caller to add anEventHandler
that will be signaled when the underlying link for thisTransactionController
has been granted credit which would then allow for transactionDeclared
andDischarge
commands to be sent to the remote Transactional Resource.Session.coordinator
(String name) Create a newTransactionController
using the provided name.TransactionController.declare
(Transaction<TransactionController> transaction) Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.TransactionController.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.TransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) Request that the remoteTransactionManager
discharge the given transaction and with the specified failure state (true for failed).TransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManager
end of the link has responded to a previousdischarge(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 previousdischarge(Transaction, boolean)
request and the transaction discharge failed for some reason.TransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionController
is locally closed.TransactionController.setCoordinator
(Coordinator coordinator) Sets theCoordinator
target to assign to the local end of thisTransactionController
.Sets theSource
to assign to the local end of thisTransactionController
.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 theTransactionController.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.addCapacityAvailableHandler
(EventHandler<TransactionController> handler) Allows the caller to add anEventHandler
that will be signaled when the underlying link for thisTransactionController
has been granted credit which would then allow for transactionDeclared
andDischarge
commands to be sent to the remote Transactional Resource.TransactionController.declare
(Transaction<TransactionController> transaction) Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.TransactionController.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.TransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) Request that the remoteTransactionManager
discharge the given transaction and with the specified failure state (true for failed).TransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManager
end of the link has responded to a previousdischarge(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 previousdischarge(Transaction, boolean)
request and the transaction discharge failed for some reason.TransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionController
is locally closed. -
Uses of TransactionController in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionclass
TransactionController
implementation that implements the abstraction around a sender link that initiates requests toDeclare
and toDischarge
AMQPTransaction
instance.Modifier and TypeMethodDescriptionProtonTransactionController.close()
ProtonSession.coordinator
(String name) ProtonTransactionController.declare
(Transaction<TransactionController> transaction) ProtonTransactionController.declaredHandler
(EventHandler<Transaction<TransactionController>> declaredEventHandler) ProtonTransactionController.declareFailureHandler
(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) ProtonTransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) ProtonTransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) ProtonTransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) ProtonTransactionController.open()
ProtonTransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler) ProtonTransactionController.setCondition
(ErrorCondition condition) ProtonTransactionController.setCoordinator
(Coordinator coordinator) ProtonTransactionController.setDesiredCapabilities
(Symbol... desiredCapabilities) ProtonTransactionController.setOfferedCapabilities
(Symbol... offeredCapabilities) ProtonTransactionController.setProperties
(Map<Symbol, Object> properties) Modifier and TypeMethodDescriptionProtonTransactionController.declare()
ProtonTransactionController.transactions()
Modifier and TypeMethodDescriptionProtonTransactionController.addCapacityAvailableHandler
(EventHandler<TransactionController> handler) ProtonTransactionController.declare
(Transaction<TransactionController> transaction) ProtonTransactionController.declaredHandler
(EventHandler<Transaction<TransactionController>> declaredEventHandler) ProtonTransactionController.declareFailureHandler
(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) ProtonTransactionController.discharge
(Transaction<TransactionController> transaction, boolean failed) ProtonTransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) ProtonTransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) ProtonTransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler)