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
Methods in org.apache.qpid.protonj2.client.impl that return OutgoingDelivery Modifier and Type Method Description OutgoingDeliveryClientOutgoingEnvelope. delivery()Methods in org.apache.qpid.protonj2.client.impl with parameters of type OutgoingDelivery Modifier and Type Method Description protected ClientStreamTrackerClientStreamSender. createTracker(OutgoingDelivery delivery)Constructors in org.apache.qpid.protonj2.client.impl with parameters of type OutgoingDelivery Constructor Description ClientOutgoingEnvelope(org.apache.qpid.protonj2.client.impl.ClientSender sender, OutgoingDelivery delivery, int messageFormat, ProtonBuffer payload, boolean complete, ClientFuture<Tracker> 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 OutgoingDeliveryOutgoingDelivery. abort()Aborts the outgoing delivery if not already settled.OutgoingDeliverySender. current()Gets the currentOutgoingDeliveryfor thisSenderif one is available.OutgoingDeliveryOutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.OutgoingDeliveryOutgoingDelivery. disposition(DeliveryState state)updates the state of the deliveryOutgoingDeliveryOutgoingDelivery. 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.OutgoingDeliverySender. 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.OutgoingDeliveryOutgoingDelivery. setLinkedResource(java.lang.Object resource)Links a given resource to thisEndpoint.OutgoingDeliveryOutgoingDelivery. setMessageFormat(int messageFormat)Sets the message-format for this Delivery, representing the 32bit value using an integer value.OutgoingDeliveryOutgoingDelivery. setTag(byte[] deliveryTag)Sets the delivery tag to assign to this outgoing delivery from the given byte array.OutgoingDeliveryOutgoingDelivery. setTag(DeliveryTag deliveryTag)Sets theDeliveryTagto assign to this outgoing delivery.OutgoingDeliveryOutgoingDelivery. settle()Settles this delivery if not already settled.OutgoingDeliveryOutgoingDelivery. 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.OutgoingDeliveryOutgoingDelivery. 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.OutgoingDeliveryOutgoingDelivery. 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 java.util.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 OutgoingDeliveryOutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.SenderSender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)Handler for updates for deliveries that have previously been sent.SenderSender. disposition(java.util.function.Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle)For each unsettled outgoing delivery that is pending in theSenderapply the given predicate and if it matches then apply the given delivery state and settled value to it.SenderSender. settle(java.util.function.Predicate<OutgoingDelivery> filter)For each unsettled outgoing delivery that is pending in theSenderapply 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 classProtonOutgoingDeliveryProton outgoing delivery implementationMethods in org.apache.qpid.protonj2.engine.impl that return OutgoingDelivery Modifier and Type Method Description OutgoingDeliveryProtonOutgoingDelivery. abort()OutgoingDeliveryProtonSender. current()OutgoingDeliveryProtonOutgoingDelivery. disposition(DeliveryState state)OutgoingDeliveryProtonOutgoingDelivery. disposition(DeliveryState state, boolean settle)OutgoingDeliveryProtonSender. next()OutgoingDeliveryProtonOutgoingDelivery. setMessageFormat(int messageFormat)OutgoingDeliveryProtonOutgoingDelivery. setTag(byte[] deliveryTag)OutgoingDeliveryProtonOutgoingDelivery. setTag(DeliveryTag deliveryTag)OutgoingDeliveryProtonOutgoingDelivery. settle()OutgoingDeliveryProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer)OutgoingDeliveryProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer, boolean complete)OutgoingDeliveryProtonOutgoingDelivery. writeBytes(ProtonBuffer buffer)Methods in org.apache.qpid.protonj2.engine.impl that return types with arguments of type OutgoingDelivery Modifier and Type Method Description java.util.Collection<OutgoingDelivery>ProtonSender. unsettled()Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type OutgoingDelivery Modifier and Type Method Description ProtonOutgoingDeliveryProtonOutgoingDelivery. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)SenderProtonSender. deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery> handler)SenderProtonSender. disposition(java.util.function.Predicate<OutgoingDelivery> filter, DeliveryState state, boolean settle)SenderProtonSender. settle(java.util.function.Predicate<OutgoingDelivery> filter)
-