Uses of Class
org.apache.qpid.protonj2.client.futures.ClientFuture
-
Uses of ClientFuture in org.apache.qpid.protonj2.client.futures
Modifier and TypeClassDescriptionclass
A more balanced implementation of a ClientFuture that works better on some platforms such as windows where the thread park and atomic operations used by a more aggressive implementation could result in poor performance.class
A more conservative implementation of a ClientFuture that is better on some platforms or resource constrained hardware where high CPU usage can be more counter productive than other variants that might spin or otherwise avoid entry into states requiring thread signaling.class
An optimized version of a ClientFuture that makes use of spin waits and other methods of reacting to asynchronous completion in a more timely manner.Modifier and TypeFieldDescriptionprotected static final AtomicIntegerFieldUpdater<ClientFuture>
ClientFuture.STATE_FIELD_UPDATER
Modifier and TypeMethodDescriptionabstract <V> ClientFuture<V>
ClientFutureFactory.createFuture()
abstract <V> ClientFuture<V>
ClientFutureFactory.createFuture
(ClientSynchronization<V> synchronization) abstract <V> ClientFuture<V>
ClientFutureFactory.createUnfailableFuture()
abstract <V> ClientFuture<V>
ClientFutureFactory.createUnfailableFuture
(ClientSynchronization<V> synchronization) -
Uses of ClientFuture in org.apache.qpid.protonj2.client.impl
Modifier and TypeFieldDescriptionprotected final ClientFuture<LinkType>
ClientLinkType.closeFuture
protected ClientFuture<ReceiverType>
ClientReceiverLinkType.drainingFuture
protected final ClientFuture<LinkType>
ClientLinkType.openFuture
Modifier and TypeMethodDescriptionClientLinkType.closeAsync()
ClientLinkType.closeAsync
(ErrorCondition error) ClientLinkType.detachAsync()
ClientLinkType.detachAsync
(ErrorCondition error) ClientLinkType.openFuture()
ClientTrackable.settlementFuture()
Modifier and TypeMethodDescriptionprotected boolean
ClientLinkType.notClosedOrFailed
(ClientFuture<?> request) protected boolean
ClientLinkType.notClosedOrFailed
(ClientFuture<?> request, ProtonType protonLink) ModifierConstructorDescriptionClientOutgoingEnvelope
(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.