Uses of Interface
org.apache.qpid.protonj2.engine.OutgoingDelivery
Packages that use OutgoingDelivery
Package
Description
-
Uses of OutgoingDelivery in org.apache.qpid.protonj2.client.impl
Fields in org.apache.qpid.protonj2.client.impl declared as OutgoingDeliveryMethods in org.apache.qpid.protonj2.client.impl that return OutgoingDeliveryConstructors in org.apache.qpid.protonj2.client.impl with parameters of type OutgoingDeliveryModifierConstructorDescriptionClientOutgoingEnvelope
(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 OutgoingDeliveryModifier 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.Methods in org.apache.qpid.protonj2.engine that return types with arguments of type OutgoingDeliveryModifier and TypeMethodDescriptionSender.unsettled()
Retrieves the list of unsettled deliveries sent from thisSender
.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type OutgoingDeliveryModifier 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
Classes in org.apache.qpid.protonj2.engine.impl that implement OutgoingDeliveryModifier and TypeClassDescriptionclass
Proton outgoing delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return OutgoingDeliveryModifier 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) Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type OutgoingDeliveryMethod parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type OutgoingDeliveryModifier 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)