Uses of Interface
org.apache.qpid.protonj2.engine.Receiver
Packages that use Receiver
Package
Description
-
Uses of Receiver in org.apache.qpid.protonj2.client.impl
Fields in org.apache.qpid.protonj2.client.impl declared as ReceiverMethods in org.apache.qpid.protonj2.client.impl that return ReceiverMethods in org.apache.qpid.protonj2.client.impl with parameters of type ReceiverModifier and TypeMethodDescriptionprotected void
ClientReceiverLinkType.handleReceiverCreditUpdated
(Receiver receiver) Constructors in org.apache.qpid.protonj2.client.impl with parameters of type ReceiverModifierConstructorDescriptionprotected
ClientReceiverLinkType
(ClientSession session, String linkId, LinkOptions<?> options, Receiver protonReceiver) -
Uses of Receiver in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return ReceiverModifier and TypeMethodDescriptionReceiver.addCredit
(int additionalCredit) Adds the given amount of credit for theReceiver
.Receiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) Handler for aborted deliveries that is called for each aborted in-progress delivery.Receiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) Receiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver.disposition
(Predicate<IncomingDelivery> filter, DeliveryState state, boolean settle) For each unsettled outgoing delivery that is pending in theReceiver
apply the given predicate and if it matches then apply the given delivery state and settled value to it.IncomingDelivery.getLink()
Create a newReceiver
link using the provided nameReceiver.setDefaultDeliveryState
(DeliveryState state) Configures a default DeliveryState to be used if a received delivery is settled/freed without any disposition state having been previously applied.Receiver.settle
(Predicate<IncomingDelivery> filter) For each unsettled outgoing delivery that is pending in theReceiver
apply the given predicate and if it matches then settle the delivery.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type ReceiverMethod parameters in org.apache.qpid.protonj2.engine with type arguments of type ReceiverModifier and TypeMethodDescriptionConnection.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. -
Uses of Receiver in org.apache.qpid.protonj2.engine.impl
Classes in org.apache.qpid.protonj2.engine.impl that implement ReceiverMethods in org.apache.qpid.protonj2.engine.impl that return ReceiverModifier and TypeMethodDescriptionProtonReceiver.creditStateUpdateHandler
(EventHandler<Receiver> handler) ProtonReceiver.deliveryAbortedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryReadHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.deliveryStateUpdatedHandler
(EventHandler<IncomingDelivery> handler) ProtonReceiver.disposition
(Predicate<IncomingDelivery> filter, DeliveryState disposition, boolean settle) ProtonReceiver.settle
(Predicate<IncomingDelivery> filter) Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type ReceiverModifier and TypeMethodDescriptionProtonReceiver.creditStateUpdateHandler
(EventHandler<Receiver> handler) ProtonConnection.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) ProtonSession.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler)