Uses of Interface
org.apache.qpid.protonj2.engine.Receiver
Package
Description
-
Uses of Receiver in org.apache.qpid.protonj2.client.impl
Modifier and TypeMethodDescriptionprotected void
ClientReceiverLinkType.handleReceiverCreditUpdated
(Receiver receiver) ModifierConstructorDescriptionprotected
ClientReceiverLinkType
(ClientSession session, String linkId, LinkOptions<?> options, Receiver protonReceiver) -
Uses of Receiver in org.apache.qpid.protonj2.engine
Modifier 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.Modifier 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
Modifier 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) Modifier and TypeMethodDescriptionProtonReceiver.creditStateUpdateHandler
(EventHandler<Receiver> handler) ProtonConnection.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler) ProtonSession.receiverOpenHandler
(EventHandler<Receiver> remoteReceiverOpenEventHandler)