Uses of Interface
org.apache.qpid.protonj2.engine.TransactionManager
-
Packages that use TransactionManager Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of TransactionManager in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return TransactionManager Modifier and Type Method Description TransactionManager
TransactionManager. 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
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
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
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
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
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
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
TransactionManager. parentEndpointClosedHandler(EventHandler<TransactionManager> handler)
Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionManager
is locally closed.TransactionManager
TransactionManager. setCoordinator(Coordinator coordinator)
Sets theCoordinator
target to assign to the local end of thisTransactionManager
.TransactionManager
TransactionManager. setSource(Source source)
Sets theSource
to assign to the local end of thisTransactionManager
.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type TransactionManager Modifier and Type Method Description 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
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
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
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
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
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
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
TransactionManager. parentEndpointClosedHandler(EventHandler<TransactionManager> handler)
Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionManager
is locally closed.Connection
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
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 TransactionManager Modifier and Type Class Description class
ProtonTransactionManager
TransactionManager
implementation that implements the abstraction around a receiver link that responds to requests toDeclare
and toDischarge
AMQPTransaction
instance.
-