Uses of Interface
org.apache.qpid.protonj2.engine.Sender
Package
Description
-
Uses of Sender in org.apache.qpid.protonj2.client.impl
ModifierConstructorDescriptionprotected
ClientSenderLinkType
(ClientSession session, String linkId, LinkOptions<?> options, Sender protonSender) -
Uses of Sender in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionSender.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) Handler for updates for deliveries that have previously been sent.Sender.disposition
(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.drained()
Called when theReceiver
has requested a drain of credit and the sender has sent all available messages.OutgoingDelivery.getLink()
Create a newSender
link using the provided name.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.settle
(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.Modifier and TypeMethodDescriptionConnection.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) Sets aEventHandler
for when an AMQP Attach frame is received from the remote peer for a sending link.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
Modifier and TypeMethodDescriptionProtonSender.creditStateUpdateHandler
(EventHandler<Sender> handler) ProtonSender.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) ProtonSender.disposition
(Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle) ProtonSender.drained()
ProtonSender.setDeliveryTagGenerator
(DeliveryTagGenerator generator) ProtonSender.settle
(Predicate<OutgoingDelivery> filter) Modifier and TypeMethodDescriptionProtonSender.creditStateUpdateHandler
(EventHandler<Sender> handler) ProtonConnection.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler) ProtonSession.senderOpenHandler
(EventHandler<Sender> remoteSenderOpenEventHandler)