Package org.apache.qpid.protonj2.client.impl

Class ClientNoOpStreamTracker

java.lang.Object

org.apache.qpid.protonj2.client.impl.ClientNoOpTracker

org.apache.qpid.protonj2.client.impl.ClientNoOpStreamTracker

All Implemented Interfaces:

StreamTracker, Tracker

public class ClientNoOpStreamTracker
extends ClientNoOpTracker
implements StreamTracker

A dummy Tracker instance that always indicates remote settlement and acceptance for StreamSender instances.

Method Summary

Modifier and Type	Method	Description
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 a Disposition back.
StreamTracker	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 a Disposition back.
StreamTracker	disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
StreamSender	sender()
StreamTracker	settle()	Settles the delivery locally, if not auto-settling.

Methods inherited from class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker

awaitAccepted, awaitAccepted, remoteSettled, remoteState, settled, settlementFuture, state

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.qpid.protonj2.client.StreamTracker

settlementFuture

Methods inherited from interface org.apache.qpid.protonj2.client.Tracker

awaitAccepted, awaitAccepted, remoteSettled, remoteState, settled, state

Method Detail

sender

public StreamSender sender()

Description copied from interface: StreamTracker

Specified by:

sender in interface StreamTracker

Specified by:

sender in interface Tracker

Overrides:

sender in class ClientNoOpTracker

Returns:

the Sender that was used to send the delivery that is being tracked.

settle

public StreamTracker settle()
                     throws ClientException

Description copied from interface: Tracker

Settles the delivery locally, if not auto-settling.

Specified by:

settle in interface StreamTracker

Specified by:

settle in interface Tracker

Overrides:

settle in class ClientNoOpTracker

Returns:

this Tracker instance.

Throws:

ClientException - if an error occurs while performing the settlement.

disposition

public StreamTracker disposition(DeliveryState state,
                                 boolean settle)
                          throws ClientException

Description copied from interface: Tracker

Updates the DeliveryState, and optionally settle the delivery as well.

Specified by:

disposition in interface StreamTracker

Specified by:

disposition in interface Tracker

Overrides:

disposition in class ClientNoOpTracker

Parameters:

state - the delivery state to apply

settle - whether to Tracker.settle() the delivery at the same time

Returns:

this Tracker instance.

Throws:

ClientException - if an error occurs while applying the given disposition

awaitSettlement

public StreamTracker awaitSettlement()
                              throws ClientException

Description copied from interface: Tracker

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 a Disposition back.

Specified by:

awaitSettlement in interface StreamTracker

Specified by:

awaitSettlement in interface Tracker

Overrides:

awaitSettlement in class ClientNoOpTracker

Returns:

this Tracker instance.

Throws:

ClientException - if an error occurs while awaiting the remote settlement.

awaitSettlement

public StreamTracker awaitSettlement(long timeout,
                                     java.util.concurrent.TimeUnit unit)
                              throws ClientException

Description copied from interface: Tracker

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 a Disposition back.

Specified by:

awaitSettlement in interface StreamTracker

Specified by:

awaitSettlement in interface Tracker

Overrides:

awaitSettlement in class ClientNoOpTracker

Parameters:

timeout - the maximum time to wait for the remote to settle.

unit - the time unit of the timeout argument.

Returns:

this Tracker instance.

Throws:

ClientException - if an error occurs while awaiting the remote settlement.