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 theTransactionManagerwhich allows theTransactionControllerto sendDeclareandDischargerequests to this manager.default TransactionManagerTransactionManager.declared(Transaction<TransactionManager> transaction, byte[] txnId) Respond to a previousDeclarerequest from the remoteTransactionControllerindicating 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 previousDeclarerequest from the remoteTransactionControllerindicating 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 previousDeclarerequest from the remoteTransactionControllerindicating that the requested transaction declaration has failed and is not active.TransactionManager.declareHandler(EventHandler<Transaction<TransactionManager>> declaredEventHandler) Called when theTransactionControllerend of the link has requested a new transaction be declared using the information provided in the givenDeclareinstance.TransactionManager.discharged(Transaction<TransactionManager> transaction) Respond to a previousDischargerequest from the remoteTransactionControllerindicating 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 previousDischargerequest from the remoteTransactionControllerindicating that the discharge resulted in an error and the transaction must be considered rolled back.TransactionManager.dischargeHandler(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) Called when theTransactionControllerend of the link has requested a current transaction be discharged using the information provided in the givenDischargeinstance.TransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler) Sets aEventHandlerfor when the parentSessionorConnectionof thisTransactionManageris locally closed.TransactionManager.setCoordinator(Coordinator coordinator) Sets theCoordinatortarget to assign to the local end of thisTransactionManager.Sets theSourceto assign to the local end of thisTransactionManager.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type TransactionManagerModifier and TypeMethodDescriptiondefault TransactionManagerTransactionManager.declared(Transaction<TransactionManager> transaction, byte[] txnId) Respond to a previousDeclarerequest from the remoteTransactionControllerindicating 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 previousDeclarerequest from the remoteTransactionControllerindicating 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 previousDeclarerequest from the remoteTransactionControllerindicating that the requested transaction declaration has failed and is not active.TransactionManager.declareHandler(EventHandler<Transaction<TransactionManager>> declaredEventHandler) Called when theTransactionControllerend of the link has requested a new transaction be declared using the information provided in the givenDeclareinstance.TransactionManager.discharged(Transaction<TransactionManager> transaction) Respond to a previousDischargerequest from the remoteTransactionControllerindicating 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 previousDischargerequest from the remoteTransactionControllerindicating that the discharge resulted in an error and the transaction must be considered rolled back.TransactionManager.dischargeHandler(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) Called when theTransactionControllerend of the link has requested a current transaction be discharged using the information provided in the givenDischargeinstance.TransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler) Sets aEventHandlerfor when the parentSessionorConnectionof thisTransactionManageris locally closed.Connection.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) Sets aEventHandlerfor when an AMQP Attach frame is received from the remote peer for a transaction coordination link.Session.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) Sets aEventHandlerfor 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 classTransactionManagerimplementation that implements the abstraction around a receiver link that responds to requests toDeclareand toDischargeAMQPTransactioninstance.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)