Uses of Interface
org.apache.qpid.protonj2.engine.Receiver
-
Packages that use Receiver Package Description org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of Receiver in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return Receiver Modifier and Type Method Description Receiver
Receiver. addCredit(int additionalCredit)
Adds the given amount of credit for theReceiver
.Receiver
Receiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Handler for aborted deliveries that is called for each aborted in-progress delivery.Receiver
Receiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
Receiver
Receiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Handler for updates to the remote state of incoming deliveries that have previously been received.Receiver
Receiver. disposition(java.util.function.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.Receiver
IncomingDelivery. getLink()
Receiver
Session. receiver(java.lang.String name)
Create a newReceiver
link using the provided nameReceiver
Receiver. 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
Receiver. settle(java.util.function.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 Receiver Modifier and Type Method Description java.util.Set<? extends Receiver>
Session. receivers()
Method parameters in org.apache.qpid.protonj2.engine with type arguments of type Receiver Modifier and Type Method Description Connection
Connection. receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler)
Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a receiving link.Session
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 Receiver Modifier and Type Class Description class
ProtonReceiver
Proton Receiver link implementation.Methods in org.apache.qpid.protonj2.engine.impl that return Receiver Modifier and Type Method Description Receiver
ProtonReceiver. creditStateUpdateHandler(EventHandler<Receiver> handler)
Receiver
ProtonReceiver. deliveryAbortedHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. deliveryReadHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. deliveryStateUpdatedHandler(EventHandler<IncomingDelivery> handler)
Receiver
ProtonReceiver. disposition(java.util.function.Predicate<IncomingDelivery> filter, DeliveryState disposition, boolean settle)
Receiver
ProtonReceiver. settle(java.util.function.Predicate<IncomingDelivery> filter)
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type Receiver Modifier and Type Method Description Receiver
ProtonReceiver. creditStateUpdateHandler(EventHandler<Receiver> handler)
ProtonConnection
ProtonConnection. receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler)
ProtonSession
ProtonSession. receiverOpenHandler(EventHandler<Receiver> remoteReceiverOpenEventHandler)
-