Uses of Interface
org.apache.qpid.protonj2.engine.Sender
-
Packages that use Sender Package Description org.apache.qpid.protonj2.client.impl org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of Sender in org.apache.qpid.protonj2.client.impl
Fields in org.apache.qpid.protonj2.client.impl declared as Sender Modifier and Type Field Description protected Sender
ClientSender. protonSender
-
Uses of Sender in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return Sender Modifier and Type Method Description Sender
Sender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Handler for updates for deliveries that have previously been sent.Sender
Sender. disposition(java.util.function.Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle)
For each unsettled outgoing delivery that is pending in theSender
apply the given predicate and if it matches then apply the given delivery state and settled value to it.Sender
Sender. drained()
Called when theReceiver
has requested a drain of credit and the sender has sent all available messages.Sender
OutgoingDelivery. getLink()
Sender
Session. sender(java.lang.String name)
Create a newSender
link using the provided name.Sender
Sender. setDeliveryTagGenerator(DeliveryTagGenerator generator)
Configures aDeliveryTagGenerator
that will be used to create and set aDeliveryTag
value on each newOutgoingDelivery
that is created and returned from thenext()
method.Sender
Sender. settle(java.util.function.Predicate<OutgoingDelivery> filter)
For each unsettled outgoing delivery that is pending in theSender
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 Sender Modifier and Type Method Description java.util.Set<? extends Sender>
Session. senders()
Method parameters in org.apache.qpid.protonj2.engine with type arguments of type Sender Modifier and Type Method Description Connection
Connection. senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link.Session
Session. senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link. -
Uses of Sender in org.apache.qpid.protonj2.engine.impl
Classes in org.apache.qpid.protonj2.engine.impl that implement Sender Modifier and Type Class Description class
ProtonSender
Proton Sender link implementation.Methods in org.apache.qpid.protonj2.engine.impl that return Sender Modifier and Type Method Description Sender
ProtonSender. creditStateUpdateHandler(EventHandler<Sender> handler)
Sender
ProtonSender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Sender
ProtonSender. disposition(java.util.function.Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle)
Sender
ProtonSender. drained()
Sender
ProtonSender. setDeliveryTagGenerator(DeliveryTagGenerator generator)
Sender
ProtonSender. settle(java.util.function.Predicate<OutgoingDelivery> filter)
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type Sender Modifier and Type Method Description Sender
ProtonSender. creditStateUpdateHandler(EventHandler<Sender> handler)
ProtonConnection
ProtonConnection. senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
ProtonSession
ProtonSession. senderOpenHandler(EventHandler<Sender> remoteSenderOpenEventHandler)
-