Uses of Interface
org.apache.qpid.protonj2.client.Tracker
-
Packages that use Tracker Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of Tracker in org.apache.qpid.protonj2.client
Subinterfaces of Tracker in org.apache.qpid.protonj2.client Modifier and Type Interface Description interface
StreamTracker
Special StreamSender relatedTracker
that is linked to anyStreamSenderMessage
instance and provides theTracker
functions for those types of messages.Methods in org.apache.qpid.protonj2.client that return Tracker Modifier and Type Method Description Tracker
Tracker. 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.Tracker
Tracker. awaitAccepted(long timeout, java.util.concurrent.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.Tracker
Tracker. 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.Tracker
Tracker. 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 aDisposition
back.Tracker
Tracker. disposition(DeliveryState state, boolean settle)
Updates the DeliveryState, and optionally settle the delivery as well.Tracker
Connection. send(Message<?> message)
Sends the givenMessage
using the internal connection sender.Tracker
Sender. send(Message<?> message)
Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.Tracker
Sender. send(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.Tracker
Tracker. settle()
Settles the delivery locally, if notauto-settling
.Tracker
Sender. 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.Tracker
Sender. trySend(Message<?> message, java.util.Map<java.lang.String,java.lang.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 Tracker Modifier and Type Method Description java.util.concurrent.Future<Tracker>
StreamTracker. settlementFuture()
Returns a future that can be used to wait for the remote to acknowledge receipt of a sent message by settling it.java.util.concurrent.Future<Tracker>
Tracker. 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 Tracker in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement Tracker Modifier and Type Class Description class
ClientNoOpStreamTracker
A dummy Tracker instance that always indicates remote settlement and acceptance forStreamSender
instances.class
ClientNoOpTracker
A dummy Tracker instance that always indicates remote settlement and acceptance.class
ClientStreamTracker
StreamTracker
implementation that relies on the ClientTracker to handle the basicOutgoingDelivery
management.Methods in org.apache.qpid.protonj2.client.impl that return Tracker Modifier and Type Method Description Tracker
ClientNoOpTracker. awaitAccepted()
Tracker
ClientNoOpTracker. awaitAccepted(long timeout, java.util.concurrent.TimeUnit unit)
Tracker
ClientNoOpTracker. awaitSettlement()
Tracker
ClientNoOpTracker. awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)
Tracker
ClientNoOpTracker. disposition(DeliveryState state, boolean settle)
Tracker
ClientConnection. send(Message<?> message)
Tracker
ClientNoOpTracker. settle()
Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type Tracker Modifier and Type Method Description java.util.concurrent.Future<Tracker>
ClientNoOpTracker. settlementFuture()
Constructor parameters in org.apache.qpid.protonj2.client.impl with type arguments of type Tracker 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.
-