Uses of Interface
org.apache.qpid.protonj2.engine.EventHandler
Package
Description
-
Uses of EventHandler in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionTransactionController.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.Endpoint.closeHandler
(EventHandler<E> remoteCloseEventHandler) Sets a EventHandler for when an AMQP Close frame is received from the remote peer.Link.creditStateUpdateHandler
(EventHandler<L> handler) Handler for link credit updates that occur after a remoteFlow
arrives.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.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.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.IncomingDelivery.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called if this delivery is aborted by theSender
.Receiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called for each aborted in-progress delivery.IncomingDelivery.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) Receiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) Session.deliveryReadHandler
(EventHandler<IncomingDelivery> delivery) Allows monitoring of incoming deliveries to receivers attached to thisSession
.IncomingDelivery.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.OutgoingDelivery.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.Receiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.Sender.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) Handler for updates for deliveries that have previously been sent.Link.detachHandler
(EventHandler<L> remoteDetachHandler) Sets aEventHandler
for when an AMQP Detach frame is received from the remote peer for thisLink
which would have been locally opened previously, the Detach from would have been marked as not having been closed.TransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) Called when theTransactionManager
end of the link has responded to a previousTransactionController.discharge(Transaction, boolean)
request and the transaction has been retired.TransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) Called when theTransactionManager
end of the link has responded to a previousTransactionController.discharge(Transaction, boolean)
request and the transaction discharge failed for some reason.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.Endpoint.engineShutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) Sets anEventHandler
that is invoked when the engine that supports thisEndpoint
is shutdown via a call toEngine.shutdown()
which indicates a desire to terminate all engine operations.Engine.errorHandler
(EventHandler<Engine> engineFailure) Sets a handler instance that will be notified when the engine encounters a fatal error.Endpoint.localCloseHandler
(EventHandler<E> localCloseHandler) Sets aEventHandler
for when an thisEndpoint
is closed locally via a call toEndpoint.close()
Typically used by clients for logging or other state update event processing.Link.localDetachHandler
(EventHandler<L> localDetachHandler) Sets aEventHandler
for when an this link is detached locally via a call toLink.detach()
This is a convenience event that supplements the normalEndpoint.localCloseHandler(EventHandler)
event point if set.Endpoint.localOpenHandler
(EventHandler<E> localOpenHandler) Sets aEventHandler
for when an thisEndpoint
is opened locally via a call toEndpoint.open()
Typically used by clients for logging or other state update event processing.Connection.negotiate
(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) If not already negotiated this method initiates the AMQP protocol negotiation phase of the connection process sending theAMQPHeader
to the remote peer.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).Link.parentEndpointClosedHandler
(EventHandler<L> handler) TransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionController
is locally closed.TransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) Sets aEventHandler
for when the parentSession
orConnection
of thisTransactionManager
is locally closed.Connection.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a receiving link.Session.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a receiving link.Connection.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link.Session.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link.Connection.sessionOpenHandler
(EventHandler<Session> remoteSessionOpenEventHandler) Sets aEventHandler
for when an AMQP Begin frame is received from the remote peer.Engine.shutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) Sets a handler instance that will be notified when the engine is shut down via a call to theEngine.shutdown()
method is called.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.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 EventHandler in org.apache.qpid.protonj2.engine.impl
Modifier and TypeMethodDescriptionProtonTransactionController.addCapacityAvailableHandler
(EventHandler<TransactionController> handler) ProtonEndpoint.closeHandler
(EventHandler<E> remoteCloseEventHandler) ProtonReceiver.creditStateUpdateHandler
(EventHandler<Receiver> handler) ProtonSender.creditStateUpdateHandler
(EventHandler<Sender> handler) ProtonTransactionController.declaredHandler
(EventHandler<Transaction<TransactionController>> declaredEventHandler) ProtonTransactionController.declareFailureHandler
(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) ProtonTransactionManager.declareHandler
(EventHandler<Transaction<TransactionManager>> declaredEventHandler) ProtonIncomingDelivery.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) ProtonIncomingDelivery.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) ProtonSession.deliveryReadHandler
(EventHandler<IncomingDelivery> deliveryReadHandler) ProtonIncomingDelivery.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) ProtonOutgoingDelivery.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) ProtonReceiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) ProtonSender.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) ProtonLink.detachHandler
(EventHandler<L> remoteDetachHandler) ProtonTransactionController.dischargedHandler
(EventHandler<Transaction<TransactionController>> dischargedEventHandler) ProtonTransactionController.dischargeFailureHandler
(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler) ProtonTransactionManager.dischargeHandler
(EventHandler<Transaction<TransactionManager>> dischargeEventHandler) ProtonEndpoint.engineShutdownHandler
(EventHandler<Engine> engineShutdownEventHandler) ProtonEngine.errorHandler
(EventHandler<Engine> handler) ProtonEndpoint.localCloseHandler
(EventHandler<E> localCloseEventHandler) ProtonLink.localDetachHandler
(EventHandler<L> localDetachHandler) ProtonEndpoint.localOpenHandler
(EventHandler<E> localOpenEventHandler) ProtonConnection.negotiate
(EventHandler<AMQPHeader> remoteAMQPHeaderHandler) ProtonEndpoint.openHandler
(EventHandler<E> remoteOpenEventHandler) ProtonLink.parentEndpointClosedHandler
(EventHandler<L> handler) ProtonTransactionController.parentEndpointClosedHandler
(EventHandler<TransactionController> handler) ProtonTransactionManager.parentEndpointClosedHandler
(EventHandler<TransactionManager> handler) ProtonConnection.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) ProtonSession.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) ProtonConnection.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) ProtonSession.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) ProtonConnection.sessionOpenHandler
(EventHandler<Session> remoteSessionOpenEventHandler) ProtonEngine.shutdownHandler
(EventHandler<Engine> handler) ProtonConnection.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) ProtonSession.transactionManagerOpenHandler
(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler) -
Uses of EventHandler in org.apache.qpid.protonj2.engine.sasl.client
Modifier and TypeMethodDescriptionSaslAuthenticator.saslComplete
(EventHandler<SaslOutcome> saslCompleteEventHandler) Sets a completion handler that will be notified once the SASL exchange has completed.