Uses of Interface
org.apache.qpid.protonj2.engine.OutgoingDelivery
Package
Description
-
Uses of OutgoingDelivery in org.apache.qpid.protonj2.client.impl
ModifierConstructorDescriptionClientOutgoingEnvelope
(ClientStreamSender sender, OutgoingDelivery delivery, int messageFormat, ProtonBuffer payload, boolean complete, ClientFuture<StreamTracker> request) Create a new In-flight Send instance that is a continuation on an existing delivery. -
Uses of OutgoingDelivery in org.apache.qpid.protonj2.engine
Modifier and TypeMethodDescriptionOutgoingDelivery.abort()
Aborts the outgoing delivery if not already settled.Sender.current()
Gets the currentOutgoingDelivery
for thisSender
if one is available.OutgoingDelivery.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.OutgoingDelivery.disposition
(DeliveryState state) updates the state of the deliveryOutgoingDelivery.disposition
(DeliveryState state, boolean settle) Update the delivery with the given disposition if not locally settled and optionally settles the delivery if not already settled.Sender.next()
When there has been no deliveries so far or the current delivery has reached a complete state this method updates the current delivery to a new instance and returns that value.OutgoingDelivery.setLinkedResource
(Object resource) Links a given resource to thisEndpoint
.OutgoingDelivery.setMessageFormat
(int messageFormat) Sets the message-format for this Delivery, representing the 32bit value using an integer value.OutgoingDelivery.setTag
(byte[] deliveryTag) Sets the delivery tag to assign to this outgoing delivery from the given byte array.OutgoingDelivery.setTag
(DeliveryTag deliveryTag) Sets theDeliveryTag
to assign to this outgoing delivery.OutgoingDelivery.settle()
Settles this delivery if not already settled.OutgoingDelivery.streamBytes
(ProtonBuffer buffer) Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call tostreamBytes(ProtonBuffer, boolean)
or a call towriteBytes(ProtonBuffer)
is made.OutgoingDelivery.streamBytes
(ProtonBuffer buffer, boolean complete) Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call tostreamBytes(ProtonBuffer, boolean)
and the buffer contents on that send are fully written.OutgoingDelivery.writeBytes
(ProtonBuffer buffer) Write the given bytes as the payload of this delivery, no additional writes can occur on this delivery if the write succeeds in sending all of the given bytes.Modifier and TypeMethodDescriptionSender.unsettled()
Retrieves the list of unsettled deliveries sent from thisSender
.Modifier and TypeMethodDescriptionOutgoingDelivery.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.Sender.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.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. -
Uses of OutgoingDelivery in org.apache.qpid.protonj2.engine.impl
Modifier and TypeClassDescriptionclass
Proton outgoing delivery implementationModifier and TypeMethodDescriptionProtonOutgoingDelivery.abort()
ProtonSender.current()
ProtonOutgoingDelivery.disposition
(DeliveryState state) ProtonOutgoingDelivery.disposition
(DeliveryState state, boolean settle) ProtonSender.next()
ProtonOutgoingDelivery.setMessageFormat
(int messageFormat) ProtonOutgoingDelivery.setTag
(byte[] deliveryTag) ProtonOutgoingDelivery.setTag
(DeliveryTag deliveryTag) ProtonOutgoingDelivery.settle()
ProtonOutgoingDelivery.streamBytes
(ProtonBuffer buffer) ProtonOutgoingDelivery.streamBytes
(ProtonBuffer buffer, boolean complete) ProtonOutgoingDelivery.writeBytes
(ProtonBuffer buffer) Modifier and TypeMethodDescriptionProtonOutgoingDelivery.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) ProtonSender.deliveryStateUpdatedHandler
(EventHandler<OutgoingDelivery> handler) ProtonSender.disposition
(Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle) ProtonSender.settle
(Predicate<OutgoingDelivery> filter)