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

Class ClientTrackable<SenderType extends ClientSenderLinkType<?>,TrackerType>

java.lang.Object

org.apache.qpid.protonj2.client.impl.ClientTrackable<SenderType,TrackerType>

Type Parameters:

SenderType - The client sender type that created this tracker

TrackerType - The actual type of tracker that is being implemented

Direct Known Subclasses:

ClientStreamTracker, ClientTracker

public abstract class ClientTrackable<SenderType extends ClientSenderLinkType<?>,TrackerType>
extends Object

Base type used to provide some common plumbing for Tracker types

Field Summary

Fields

Modifier and Type	Field	Description
protected final OutgoingDelivery	delivery
protected static final AtomicReferenceFieldUpdater<ClientTrackable,DeliveryState>	REMOTEL_DELIVERY_STATE_UPDATER
protected static final AtomicIntegerFieldUpdater<ClientTrackable>	REMOTELY_SETTLED_UPDATER
protected final SenderType	sender

Method Summary

Modifier and Type	Method	Description
TrackerType	awaitAccepted()
TrackerType	awaitAccepted(long timeout, TimeUnit unit)
TrackerType	awaitSettlement()
TrackerType	awaitSettlement(long timeout, TimeUnit unit)
TrackerType	disposition(DeliveryState state, boolean settle)
boolean	remoteSettled()
DeliveryState	remoteState()
protected abstract TrackerType	self()
TrackerType	settle()
boolean	settled()
ClientFuture<TrackerType>	settlementFuture()
DeliveryState	state()

Methods inherited from class java.lang.Object

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

Field Details

sender

protected final SenderType extends ClientSenderLinkType<?> sender

delivery

protected final OutgoingDelivery delivery

REMOTELY_SETTLED_UPDATER

protected static final AtomicIntegerFieldUpdater<ClientTrackable> REMOTELY_SETTLED_UPDATER

REMOTEL_DELIVERY_STATE_UPDATER

protected static final AtomicReferenceFieldUpdater<ClientTrackable,DeliveryState> REMOTEL_DELIVERY_STATE_UPDATER

Method Details

self

protected abstract TrackerType self()

state

public DeliveryState state()

remoteState

public DeliveryState remoteState()

remoteSettled

public boolean remoteSettled()

disposition

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

Throws:

ClientException

settle

public TrackerType settle()
                   throws ClientException

Throws:

ClientException

settled

public boolean settled()

settlementFuture

public ClientFuture<TrackerType> settlementFuture()

awaitSettlement

public TrackerType awaitSettlement()
                            throws ClientException

Throws:

ClientException

awaitSettlement

public TrackerType awaitSettlement(long timeout,
 TimeUnit unit)
                            throws ClientException

Throws:

ClientException

awaitAccepted

public TrackerType awaitAccepted()
                          throws ClientException

Throws:

ClientException

awaitAccepted

public TrackerType awaitAccepted(long timeout,
 TimeUnit unit)
                          throws ClientException

Throws:

ClientException