Uses of Interface
org.apache.qpid.protonj2.engine.EventHandler
Packages that use EventHandler
Package
Description
-
Uses of EventHandler in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine with parameters of type EventHandlerModifier and TypeMethodDescriptionTransactionController.addCapacityAvailableHandler(EventHandler<TransactionController> handler) Allows the caller to add anEventHandlerthat will be signaled when the underlying link for thisTransactionControllerhas been granted credit which would then allow for transactionDeclaredandDischargecommands 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 remoteFlowarrives.TransactionController.declaredHandler(EventHandler<Transaction<TransactionController>> declaredEventHandler) Called when theTransactionManagerend of the link has responded to a previousDeclarerequest and the transaction can now be used to enroll deliveries into the active transaction.TransactionController.declareFailureHandler(EventHandler<Transaction<TransactionController>> declareFailureEventHandler) Called when theTransactionManagerend of the link responds to aTransactiondeclaration with anRejectedoutcome indicating that the transaction could not be successfully declared.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.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 aEventHandlerfor when an AMQP Detach frame is received from the remote peer for thisLinkwhich 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 theTransactionManagerend 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 theTransactionManagerend 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 theTransactionControllerend of the link has requested a current transaction be discharged using the information provided in the givenDischargeinstance.Endpoint.engineShutdownHandler(EventHandler<Engine> engineShutdownEventHandler) Sets anEventHandlerthat is invoked when the engine that supports thisEndpointis 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 aEventHandlerfor when an thisEndpointis 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 aEventHandlerfor 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 aEventHandlerfor when an thisEndpointis 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 theAMQPHeaderto the remote peer.Endpoint.openHandler(EventHandler<E> remoteOpenEventHandler) Sets a EventHandler for when an AMQP Open frame is received from the remote peer.default EngineEngine.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 aEventHandlerfor when the parentSessionorConnectionof thisTransactionControlleris locally closed.TransactionManager.parentEndpointClosedHandler(EventHandler<TransactionManager> handler) Sets aEventHandlerfor when the parentSessionorConnectionof thisTransactionManageris locally closed.Connection.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler) Sets aEventHandlerfor when an AMQP Attach frame is received from the remote peer for a receiving link.Session.receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler) Sets aEventHandlerfor when an AMQP Attach frame is received from the remote peer for a receiving link.Connection.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandlerfor when an AMQP Attach frame is received from the remote peer for a sending link.Session.senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandlerfor when an AMQP Attach frame is received from the remote peer for a sending link.Connection.sessionOpenHandler(EventHandler<Session> remoteSessionOpenEventHandler) Sets aEventHandlerfor 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 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 EventHandler in org.apache.qpid.protonj2.engine.impl
Methods in org.apache.qpid.protonj2.engine.impl with parameters of type EventHandlerModifier 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
Methods in org.apache.qpid.protonj2.engine.sasl.client with parameters of type EventHandlerModifier and TypeMethodDescriptionSaslAuthenticator.saslComplete(EventHandler<SaslOutcome> saslCompleteEventHandler) Sets a completion handler that will be notified once the SASL exchange has completed.