Uses of Interface
org.apache.qpid.protonj2.engine.TransactionController
Packages that use TransactionController
-
Uses of TransactionController in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return TransactionControllerModifier and TypeMethodDescriptionTransactionController.addCapacityAvailableHandler(EventHandler<TransactionController> handler) Allows the caller to add anEventHandlerthat will be signaled when the underlying link for thisTransactionControllerhas been granted credit which would then allow for transactionDeclaredandDischargecommands to be sent to the remote Transactional Resource.Session.coordinator(String name) Create a newTransactionControllerusing the provided name.TransactionController.declare(Transaction<TransactionController> transaction) Request that the remoteTransactionManagerdeclare a new transaction and respond with a new transaction Id for that transaction.TransactionController.declaredHandler(EventHandler<Transaction<TransactionController>> declaredEventHandler) Called when theTransactionManagerend of the link has responded to a previousDeclarerequest and the transaction can now be used to enroll deliveries into the active transaction.TransactionController.declareFailureHandler(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) Called when theTransactionManagerend of the link responds to aTransactiondeclaration with anRejectedoutcome indicating that the transaction could not be successfully declared.TransactionController.discharge(Transaction<TransactionController> transaction, boolean failed) Request that the remoteTransactionManagerdischarge the given transaction and with the specified failure state (true for failed).TransactionController.dischargedHandler(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManagerend 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 theTransactionManagerend 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 aEventHandlerfor when the parentSessionorConnectionof thisTransactionControlleris locally closed.TransactionController.setCoordinator(Coordinator coordinator) Sets theCoordinatortarget to assign to the local end of thisTransactionController.Sets theSourceto assign to the local end of thisTransactionController.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type TransactionControllerModifier and TypeMethodDescriptionTransactionController.declare()Request that the remoteTransactionManagerdeclare a new transaction and respond with a new transaction Id for that transaction.TransactionController.newTransaction()Creates a newTransactioninstances that is returned in theTransactionState.IDLEstate which can be populated with application specific attachments or assigned a linked resource prior to calling theTransactionController.transactions()Returns a list ofTransactionobjects that are active within thisTransactionControllerwhich have not reached a terminal state meaning they have not been successfully discharged and have not failed in either theDeclarephase or theDischargephase.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type TransactionControllerModifier and TypeMethodDescriptionTransactionController.addCapacityAvailableHandler(EventHandler<TransactionController> handler) Allows the caller to add anEventHandlerthat will be signaled when the underlying link for thisTransactionControllerhas been granted credit which would then allow for transactionDeclaredandDischargecommands to be sent to the remote Transactional Resource.TransactionController.declare(Transaction<TransactionController> transaction) Request that the remoteTransactionManagerdeclare a new transaction and respond with a new transaction Id for that transaction.TransactionController.declaredHandler(EventHandler<Transaction<TransactionController>> declaredEventHandler) Called when theTransactionManagerend of the link has responded to a previousDeclarerequest and the transaction can now be used to enroll deliveries into the active transaction.TransactionController.declareFailureHandler(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) Called when theTransactionManagerend of the link responds to aTransactiondeclaration with anRejectedoutcome indicating that the transaction could not be successfully declared.TransactionController.discharge(Transaction<TransactionController> transaction, boolean failed) Request that the remoteTransactionManagerdischarge the given transaction and with the specified failure state (true for failed).TransactionController.dischargedHandler(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManagerend 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 theTransactionManagerend 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 aEventHandlerfor when the parentSessionorConnectionof thisTransactionControlleris locally closed. -
Uses of TransactionController in org.apache.qpid.protonj2.engine.impl
Classes in org.apache.qpid.protonj2.engine.impl that implement TransactionControllerModifier and TypeClassDescriptionclassTransactionControllerimplementation that implements the abstraction around a sender link that initiates requests toDeclareand toDischargeAMQPTransactioninstance.Methods in org.apache.qpid.protonj2.engine.impl that return TransactionControllerModifier 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) Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type TransactionControllerModifier and TypeMethodDescriptionProtonTransactionController.declare()ProtonTransactionController.transactions()Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type TransactionControllerModifier 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)