Uses of Interface
org.apache.qpid.protonj2.client.StreamTracker
-
Packages that use StreamTracker Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of StreamTracker in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return StreamTracker Modifier and Type Method Description StreamTracker
StreamTracker. awaitAccepted()
Waits if necessary for the remote to settle the sent delivery with anAccepted
disposition unless it has either already been settled and accepted or the original delivery was sent settled in which case the remote will not send aDisposition
back.StreamTracker
StreamTracker. awaitAccepted(long timeout, TimeUnit unit)
Waits if necessary for the remote to settle the sent delivery with anAccepted
disposition unless it has either already been settled and accepted or the original delivery was sent settled in which case the remote will not send aDisposition
back.StreamTracker
StreamTracker. awaitSettlement()
Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send aDisposition
back.StreamTracker
StreamTracker. awaitSettlement(long timeout, TimeUnit unit)
Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send aDisposition
back.StreamTracker
StreamTracker. disposition(DeliveryState state, boolean settle)
Updates the DeliveryState, and optionally settle the delivery as well.StreamTracker
StreamSender. send(Message<?> message)
Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit or there is a streaming send ongoing.StreamTracker
StreamSender. send(Message<?> message, Map<String,Object> deliveryAnnotations)
Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit or there is a streaming send ongoing.StreamTracker
StreamTracker. settle()
Settles the delivery locally, if notauto-settling
.StreamTracker
StreamSenderMessage. tracker()
StreamTracker
StreamSender. trySend(Message<?> message)
Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt or a streaming send is ongoing.StreamTracker
StreamSender. trySend(Message<?> message, Map<String,Object> deliveryAnnotations)
Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.Methods in org.apache.qpid.protonj2.client that return types with arguments of type StreamTracker Modifier and Type Method Description Future<StreamTracker>
StreamTracker. settlementFuture()
Returns a future that can be used to wait for the remote to acknowledge receipt of a sent message by settling it. -
Uses of StreamTracker in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement StreamTracker Modifier and Type Class Description class
ClientNoOpStreamTracker
A dummy Tracker instance that always indicates remote settlement and acceptance forStreamSender
instances.class
ClientStreamTracker
StreamTracker
implementation that relies on the ClientTracker to handle the basicOutgoingDelivery
management.Methods in org.apache.qpid.protonj2.client.impl that return StreamTracker Modifier and Type Method Description StreamTracker
ClientNoOpStreamTracker. awaitAccepted()
StreamTracker
ClientNoOpStreamTracker. awaitAccepted(long timeout, TimeUnit unit)
StreamTracker
ClientNoOpStreamTracker. awaitSettlement()
StreamTracker
ClientNoOpStreamTracker. awaitSettlement(long timeout, TimeUnit unit)
StreamTracker
ClientNoOpStreamTracker. disposition(DeliveryState state, boolean settle)
protected StreamTracker
ClientStreamTracker. self()
StreamTracker
ClientStreamSender. send(Message<?> message)
StreamTracker
ClientStreamSender. send(Message<?> message, Map<String,Object> deliveryAnnotations)
StreamTracker
ClientNoOpStreamTracker. settle()
StreamTracker
ClientStreamSender. trySend(Message<?> message)
StreamTracker
ClientStreamSender. trySend(Message<?> message, Map<String,Object> deliveryAnnotations)
Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type StreamTracker Modifier and Type Method Description Future<StreamTracker>
ClientNoOpStreamTracker. settlementFuture()
Constructor parameters in org.apache.qpid.protonj2.client.impl with type arguments of type StreamTracker 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.
-