Uses of Class
org.apache.qpid.protonj2.client.futures.ClientFuture
-
Packages that use ClientFuture Package Description org.apache.qpid.protonj2.client.futures org.apache.qpid.protonj2.client.impl -
-
Uses of ClientFuture in org.apache.qpid.protonj2.client.futures
Subclasses of ClientFuture in org.apache.qpid.protonj2.client.futures Modifier and Type Class Description class
BalancedClientFuture<V>
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
ConservativeClientFuture<V>
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
ProgressiveClientFuture<V>
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.Fields in org.apache.qpid.protonj2.client.futures with type parameters of type ClientFuture Modifier and Type Field Description protected static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<ClientFuture>
ClientFuture. STATE_FIELD_UPDATER
Methods in org.apache.qpid.protonj2.client.futures that return ClientFuture Modifier and Type Method Description abstract <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
Fields in org.apache.qpid.protonj2.client.impl declared as ClientFuture Modifier and Type Field Description protected ClientFuture<Sender>
ClientSender. closeFuture
protected ClientFuture<Sender>
ClientSender. openFuture
Methods in org.apache.qpid.protonj2.client.impl that return ClientFuture Modifier and Type Method Description ClientFuture<Receiver>
ClientReceiver. closeAsync()
ClientFuture<Receiver>
ClientReceiver. closeAsync(ErrorCondition error)
ClientFuture<Receiver>
ClientStreamReceiver. closeAsync()
ClientFuture<Receiver>
ClientStreamReceiver. closeAsync(ErrorCondition error)
ClientFuture<Receiver>
ClientReceiver. detachAsync()
ClientFuture<Receiver>
ClientReceiver. detachAsync(ErrorCondition error)
ClientFuture<Receiver>
ClientStreamReceiver. detachAsync()
ClientFuture<Receiver>
ClientStreamReceiver. detachAsync(ErrorCondition error)
ClientFuture<Receiver>
ClientStreamReceiver. openFuture()
Methods in org.apache.qpid.protonj2.client.impl with parameters of type ClientFuture Modifier and Type Method Description ClientTransactionContext
ClientTransactionContext. begin(ClientFuture<Session> beginFuture)
Begin a new transaction if one is not already in play.ClientTransactionContext
ClientTransactionContext. commit(ClientFuture<Session> commitFuture, boolean startNew)
Commits the current transaction if one is active and is not failed into a roll-back only state.ClientTransactionContext
ClientTransactionContext. rollback(ClientFuture<Session> rollbackFuture, boolean startNew)
Rolls back the current transaction if one is active.Constructors in org.apache.qpid.protonj2.client.impl with parameters of type ClientFuture 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.
-