TransactionController |
TransactionController.addCapacityAvailableHandler(EventHandler<TransactionController> handler) |
Allows the caller to add an EventHandler that will be signaled when the underlying
link for this TransactionController has been granted credit which would then allow for
transaction Declared and Discharge commands to be sent to the remote Transactional
Resource.
|
E |
Endpoint.closeHandler(EventHandler<E> remoteCloseEventHandler) |
Sets a EventHandler for when an AMQP Close frame is received from the remote peer.
|
L |
Link.creditStateUpdateHandler(EventHandler<L> handler) |
Handler for link credit updates that occur after a remote Flow arrives.
|
TransactionController |
TransactionController.declaredHandler(EventHandler<Transaction<TransactionController>> declaredEventHandler) |
Called when the TransactionManager end of the link has responded to a previous
Declare request and the transaction can now be used to enroll deliveries into the
active transaction.
|
TransactionController |
TransactionController.declareFailureHandler(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) |
|
TransactionManager |
TransactionManager.declareHandler(EventHandler<Transaction<TransactionManager>> declaredEventHandler) |
Called when the TransactionController end of the link has requested a new transaction be
declared using the information provided in the given Declare instance.
|
IncomingDelivery |
IncomingDelivery.deliveryAbortedHandler(EventHandler<IncomingDelivery> handler) |
Handler for aborted deliveries that is called if this delivery is aborted by the Sender .
|
Receiver |
Receiver.deliveryAbortedHandler(EventHandler<IncomingDelivery> handler) |
Handler for aborted deliveries that is called for each aborted in-progress delivery.
|
IncomingDelivery |
IncomingDelivery.deliveryReadHandler(EventHandler<IncomingDelivery> handler) |
Handler for incoming deliveries that is called for each incoming Transfer frame that comprises
either one complete delivery or a chunk of a split framed Transfer .
|
Receiver |
Receiver.deliveryReadHandler(EventHandler<IncomingDelivery> handler) |
Handler for incoming deliveries that is called for each incoming Transfer frame that comprises
either one complete delivery or a chunk of a split framed Transfer .
|
Session |
Session.deliveryReadHandler(EventHandler<IncomingDelivery> delivery) |
Allows monitoring of incoming deliveries to receivers attached to this Session .
|
IncomingDelivery |
IncomingDelivery.deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler) |
Handler for updates to the remote state of incoming deliveries that have previously been received.
|
OutgoingDelivery |
OutgoingDelivery.deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler) |
Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.
|
Receiver |
Receiver.deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler) |
Handler for updates to the remote state of incoming deliveries that have previously been received.
|
Sender |
Sender.deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler) |
Handler for updates for deliveries that have previously been sent.
|
L |
Link.detachHandler(EventHandler<L> remoteDetachHandler) |
Sets a EventHandler for when an AMQP Detach frame is received from the remote peer for this
Link which would have been locally opened previously, the Detach from would have been marked
as not having been closed.
|
TransactionController |
TransactionController.dischargedHandler(EventHandler<Transaction<TransactionController>> dischargedEventHandler) |
|
TransactionController |
TransactionController.dischargeFailureHandler(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) |
|
TransactionManager |
TransactionManager.dischargeHandler(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) |
Called when the TransactionController end of the link has requested a current transaction be
discharged using the information provided in the given Discharge instance.
|
E |
Endpoint.engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler) |
Sets an EventHandler that is invoked when the engine that supports this Endpoint is shutdown
via a call to Engine.shutdown() which indicates a desire to terminate all engine operations.
|
Engine |
Engine.errorHandler(EventHandler<Engine> engineFailure) |
Sets a handler instance that will be notified when the engine encounters a fatal error.
|
E |
Endpoint.localCloseHandler(EventHandler<E> localCloseHandler) |
|
L |
Link.localDetachHandler(EventHandler<L> localDetachHandler) |
|
E |
Endpoint.localOpenHandler(EventHandler<E> localOpenHandler) |
|
Connection |
Connection.negotiate(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) |
If not already negotiated this method initiates the AMQP protocol negotiation phase of
the connection process sending the AMQPHeader to the remote peer.
|
E |
Endpoint.openHandler(EventHandler<E> remoteOpenEventHandler) |
Sets a EventHandler for when an AMQP Open frame is received from the remote peer.
|
default Engine |
Engine.outputHandler(EventHandler<ProtonBuffer> output) |
Sets a handler instance that will be notified when data from the engine is ready to
be written to some output sink (socket etc).
|
L |
Link.parentEndpointClosedHandler(EventHandler<L> handler) |
|
TransactionController |
TransactionController.parentEndpointClosedHandler(EventHandler<TransactionController> handler) |
|
TransactionManager |
TransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler) |
|
Connection |
Connection.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a receiving link.
|
Session |
Session.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a receiving link.
|
Connection |
Connection.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a sending link.
|
Session |
Session.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a sending link.
|
Connection |
Connection.sessionOpenHandler(EventHandler<Session> remoteSessionOpenEventHandler) |
Sets a EventHandler for when an AMQP Begin frame is received from the remote peer.
|
Engine |
Engine.shutdownHandler(EventHandler<Engine> engineShutdownEventHandler) |
Sets a handler instance that will be notified when the engine is shut down via a call to the
Engine.shutdown() method is called.
|
Connection |
Connection.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a transaction
coordination link.
|
Session |
Session.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) |
Sets a EventHandler for when an AMQP Attach frame is received from the remote peer for a transaction
coordination link.
|