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 StreamTrackerStreamTracker. 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 aDispositionback.StreamTrackerStreamTracker. awaitSettlement(long timeout, java.util.concurrent.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 aDispositionback.StreamTrackerStreamTracker. disposition(DeliveryState state, boolean settle)Updates the DeliveryState, and optionally settle the delivery as well.StreamTrackerStreamTracker. settle()Settles the delivery locally, if notauto-settling.StreamTrackerStreamSenderMessage. tracker() -
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 classClientNoOpStreamTrackerA dummy Tracker instance that always indicates remote settlement and acceptance forStreamSenderinstances.classClientStreamTrackerStreamTrackerimplementation that relies on the ClientTracker to handle the basicOutgoingDeliverymanagement.Methods in org.apache.qpid.protonj2.client.impl that return StreamTracker Modifier and Type Method Description StreamTrackerClientNoOpStreamTracker. awaitSettlement()StreamTrackerClientNoOpStreamTracker. awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)StreamTrackerClientStreamTracker. awaitSettlement()StreamTrackerClientStreamTracker. awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)StreamTrackerClientNoOpStreamTracker. disposition(DeliveryState state, boolean settle)StreamTrackerClientStreamTracker. disposition(DeliveryState state, boolean settle)StreamTrackerClientStreamSender. send(Message<?> message)StreamTrackerClientStreamSender. send(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)StreamTrackerClientNoOpStreamTracker. settle()StreamTrackerClientStreamTracker. settle()StreamTrackerClientStreamSender. trySend(Message<?> message)StreamTrackerClientStreamSender. trySend(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
-