Uses of Interface
org.apache.qpid.protonj2.engine.OutgoingDelivery
-
Packages that use OutgoingDelivery Package Description org.apache.qpid.protonj2.client.impl org.apache.qpid.protonj2.engine org.apache.qpid.protonj2.engine.impl -
-
Uses of OutgoingDelivery in org.apache.qpid.protonj2.client.impl
Fields in org.apache.qpid.protonj2.client.impl declared as OutgoingDelivery Modifier and Type Field Description protected OutgoingDelivery
ClientTrackable. delivery
Methods in org.apache.qpid.protonj2.client.impl that return OutgoingDelivery Modifier and Type Method Description OutgoingDelivery
ClientStreamSender.ClientOutgoingEnvelope. delivery()
Constructors in org.apache.qpid.protonj2.client.impl with parameters of type OutgoingDelivery Constructor Description ClientOutgoingEnvelope(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
Methods in org.apache.qpid.protonj2.engine that return OutgoingDelivery Modifier and Type Method Description OutgoingDelivery
OutgoingDelivery. abort()
Aborts the outgoing delivery if not already settled.OutgoingDelivery
Sender. current()
Gets the currentOutgoingDelivery
for thisSender
if one is available.OutgoingDelivery
OutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.OutgoingDelivery
OutgoingDelivery. disposition(DeliveryState state)
updates the state of the deliveryOutgoingDelivery
OutgoingDelivery. 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.OutgoingDelivery
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
OutgoingDelivery. setLinkedResource(Object resource)
Links a given resource to thisEndpoint
.OutgoingDelivery
OutgoingDelivery. setMessageFormat(int messageFormat)
Sets the message-format for this Delivery, representing the 32bit value using an integer value.OutgoingDelivery
OutgoingDelivery. setTag(byte[] deliveryTag)
Sets the delivery tag to assign to this outgoing delivery from the given byte array.OutgoingDelivery
OutgoingDelivery. setTag(DeliveryTag deliveryTag)
Sets theDeliveryTag
to assign to this outgoing delivery.OutgoingDelivery
OutgoingDelivery. settle()
Settles this delivery if not already settled.OutgoingDelivery
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
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
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.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type OutgoingDelivery Modifier and Type Method Description Collection<OutgoingDelivery>
Sender. unsettled()
Retrieves the list of unsettled deliveries sent from thisSender
.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type OutgoingDelivery Modifier and Type Method Description OutgoingDelivery
OutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.Sender
Sender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Handler for updates for deliveries that have previously been sent.Sender
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
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
Classes in org.apache.qpid.protonj2.engine.impl that implement OutgoingDelivery Modifier and Type Class Description class
ProtonOutgoingDelivery
Proton outgoing delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return OutgoingDelivery Modifier and Type Method Description OutgoingDelivery
ProtonOutgoingDelivery. abort()
OutgoingDelivery
ProtonSender. current()
OutgoingDelivery
ProtonOutgoingDelivery. disposition(DeliveryState state)
OutgoingDelivery
ProtonOutgoingDelivery. disposition(DeliveryState state, boolean settle)
OutgoingDelivery
ProtonSender. next()
OutgoingDelivery
ProtonOutgoingDelivery. setMessageFormat(int messageFormat)
OutgoingDelivery
ProtonOutgoingDelivery. setTag(byte[] deliveryTag)
OutgoingDelivery
ProtonOutgoingDelivery. setTag(DeliveryTag deliveryTag)
OutgoingDelivery
ProtonOutgoingDelivery. settle()
OutgoingDelivery
ProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer)
OutgoingDelivery
ProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer, boolean complete)
OutgoingDelivery
ProtonOutgoingDelivery. writeBytes(ProtonBuffer buffer)
Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type OutgoingDelivery Modifier and Type Method Description Collection<OutgoingDelivery>
ProtonSender. unsettled()
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type OutgoingDelivery Modifier and Type Method Description ProtonOutgoingDelivery
ProtonOutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Sender
ProtonSender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)
Sender
ProtonSender. disposition(Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle)
Sender
ProtonSender. settle(Predicate<OutgoingDelivery> filter)
-