Uses of Interface
org.apache.qpid.protonj2.engine.TransactionController
-
Packages that use TransactionController Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of TransactionController in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return TransactionController Modifier and Type Method Description TransactionController
TransactionController. 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
Session. coordinator(java.lang.String name)
Create a newTransactionController
using the provided name.TransactionController
TransactionController. declare(Transaction<TransactionController> transaction)
Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.TransactionController
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
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
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
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
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
TransactionController. parentEndpointClosedHandler(EventHandler<TransactionController> handler)
Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionController
is locally closed.TransactionController
TransactionController. setCoordinator(Coordinator coordinator)
Sets theCoordinator
target to assign to the local end of thisTransactionController
.TransactionController
TransactionController. setSource(Source source)
Sets theSource
to assign to the local end of thisTransactionController
.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type TransactionController Modifier and Type Method Description Transaction<TransactionController>
TransactionController. declare()
Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.Transaction<TransactionController>
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 thejava.util.Collection<Transaction<TransactionController>>
TransactionController. 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.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type TransactionController Modifier and Type Method Description TransactionController
TransactionController. 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
TransactionController. declare(Transaction<TransactionController> transaction)
Request that the remoteTransactionManager
declare a new transaction and respond with a new transaction Id for that transaction.TransactionController
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
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
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
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
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
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
Classes in org.apache.qpid.protonj2.engine.impl that implement TransactionController Modifier and Type Class Description class
ProtonTransactionController
TransactionController
implementation that implements the abstraction around a sender link that initiates requests toDeclare
and toDischarge
AMQPTransaction
instance.Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type TransactionController Modifier and Type Method Description Transaction<TransactionController>
ProtonTransactionController. declare()
java.util.Collection<Transaction<TransactionController>>
ProtonTransactionController. transactions()
-