Uses of Interface
org.apache.qpid.protonj2.engine.EventHandler

Packages that use EventHandler

Package	Description
org.apache.qpid.protonj2.engine
org.apache.qpid.protonj2.engine.impl
org.apache.qpid.protonj2.engine.sasl.client

Uses of EventHandler in org.apache.qpid.protonj2.engine

Methods in org.apache.qpid.protonj2.engine with parameters of type EventHandler

Modifier and Type	Method	Description
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)	Called when the TransactionManager end of the link responds to a Transaction declaration with an Rejected outcome indicating that the transaction could not be successfully declared.
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.
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)	Called when the TransactionManager end of the link has responded to a previous TransactionController.discharge(Transaction, boolean) request and the transaction has been retired.
TransactionController	TransactionController.dischargeFailureHandler(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler)	Called when the TransactionManager end of the link has responded to a previous TransactionController.discharge(Transaction, boolean) request and the transaction discharge failed for some reason.
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)	Sets a EventHandler for when an this Endpoint is closed locally via a call to Endpoint.close() Typically used by clients for logging or other state update event processing.
L	Link.localDetachHandler(EventHandler<L> localDetachHandler)	Sets a EventHandler for when an this link is detached locally via a call to Link.detach() This is a convenience event that supplements the normal Endpoint.localCloseHandler(EventHandler) event point if set.
E	Endpoint.localOpenHandler(EventHandler<E> localOpenHandler)	Sets a EventHandler for when an this Endpoint is opened locally via a call to Endpoint.open() Typically used by clients for logging or other state update event processing.
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)	Sets a EventHandler for when the parent Session or Connection of this link is locally closed.
TransactionController	TransactionController.parentEndpointClosedHandler(EventHandler<TransactionController> handler)	Sets a EventHandler for when the parent Session or Connection of this TransactionController is locally closed.
TransactionManager	TransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler)	Sets a EventHandler for when the parent Session or Connection of this TransactionManager is locally closed.
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.

Uses of EventHandler in org.apache.qpid.protonj2.engine.impl

Methods in org.apache.qpid.protonj2.engine.impl with parameters of type EventHandler

Modifier and Type	Method	Description
ProtonTransactionController	ProtonTransactionController.addCapacityAvailableHandler(EventHandler<TransactionController> handler)
E	ProtonEndpoint.closeHandler(EventHandler<E> remoteCloseEventHandler)
Receiver	ProtonReceiver.creditStateUpdateHandler(EventHandler<Receiver> handler)
Sender	ProtonSender.creditStateUpdateHandler(EventHandler<Sender> handler)
TransactionController	ProtonTransactionController.declaredHandler(EventHandler<Transaction<TransactionController>> declaredEventHandler)
TransactionController	ProtonTransactionController.declareFailureHandler(EventHandler<Transaction<TransactionController>> declareFailureEventHandler)
TransactionManager	ProtonTransactionManager.declareHandler(EventHandler<Transaction<TransactionManager>> declaredEventHandler)
ProtonIncomingDelivery	ProtonIncomingDelivery.deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Receiver	ProtonReceiver.deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
ProtonIncomingDelivery	ProtonIncomingDelivery.deliveryReadHandler(EventHandler<IncomingDelivery> handler)
Receiver	ProtonReceiver.deliveryReadHandler(EventHandler<IncomingDelivery> handler)
ProtonIncomingDelivery	ProtonIncomingDelivery.deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
ProtonOutgoingDelivery	ProtonOutgoingDelivery.deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Receiver	ProtonReceiver.deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Sender	ProtonSender.deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
L	ProtonLink.detachHandler(EventHandler<L> remoteDetachHandler)
TransactionController	ProtonTransactionController.dischargedHandler(EventHandler<Transaction<TransactionController>> dischargedEventHandler)
TransactionController	ProtonTransactionController.dischargeFailureHandler(EventHandler<Transaction<TransactionController>> dischargeFailureEventHandler)
TransactionManager	ProtonTransactionManager.dischargeHandler(EventHandler<Transaction<TransactionManager>> dischargeEventHandler)
E	ProtonEndpoint.engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler)
ProtonEngine	ProtonEngine.errorHandler(EventHandler<Engine> handler)
E	ProtonEndpoint.localCloseHandler(EventHandler<E> localCloseEventHandler)
L	ProtonLink.localDetachHandler(EventHandler<L> localDetachHandler)
E	ProtonEndpoint.localOpenHandler(EventHandler<E> localOpenEventHandler)
Connection	ProtonConnection.negotiate(EventHandler<AMQPHeader> remoteAMQPHeaderHandler)
E	ProtonEndpoint.openHandler(EventHandler<E> remoteOpenEventHandler)
L	ProtonLink.parentEndpointClosedHandler(EventHandler<L> handler)
TransactionController	ProtonTransactionController.parentEndpointClosedHandler(EventHandler<TransactionController> handler)
TransactionManager	ProtonTransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler)
ProtonConnection	ProtonConnection.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler)
ProtonSession	ProtonSession.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler)
ProtonConnection	ProtonConnection.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
ProtonSession	ProtonSession.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
ProtonConnection	ProtonConnection.sessionOpenHandler(EventHandler<Session> remoteSessionOpenEventHandler)
ProtonEngine	ProtonEngine.shutdownHandler(EventHandler<Engine> handler)
ProtonConnection	ProtonConnection.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler)
ProtonSession	ProtonSession.transactionManagerOpenHandler(EventHandler<TransactionManager> remoteTxnManagerOpenEventHandler)

Uses of EventHandler in org.apache.qpid.protonj2.engine.sasl.client

Methods in org.apache.qpid.protonj2.engine.sasl.client with parameters of type EventHandler

Modifier and Type	Method	Description
SaslAuthenticator	SaslAuthenticator.saslComplete(EventHandler<SaslOutcome> saslCompleteEventHandler)	Sets a completion handler that will be notified once the SASL exchange has completed.