com.hazelcast.client.spi.impl

Class ClientInvocationFuture

java.lang.Object

com.hazelcast.spi.impl.AbstractInvocationFuture<ClientMessage>

com.hazelcast.client.spi.impl.ClientInvocationFuture

All Implemented Interfaces:

ICompletableFuture<ClientMessage>, InternalCompletableFuture<ClientMessage>, Future<ClientMessage>

public class ClientInvocationFuture
extends AbstractInvocationFuture<ClientMessage>

Field Summary

Fields inherited from class com.hazelcast.spi.impl.AbstractInvocationFuture

defaultExecutor, logger

Constructor Summary

Constructors

Constructor and Description
ClientInvocationFuture(ClientInvocation invocation, Executor internalExecutor, ClientMessage request, ILogger logger, CallIdSequence callIdSequence)

Method Summary

Modifier and Type	Method and Description
void	andThen(ExecutionCallback<ClientMessage> callback) Registers a callback that will run after this future is completed.
void	andThen(ExecutionCallback<ClientMessage> callback, Executor executor) Registers a callback that will run with the provided executor after this future is completed.
ClientInvocation	getInvocation()
protected String	invocationToString()
protected TimeoutException	newTimeoutException(long timeout, TimeUnit unit)
protected void	onComplete()
protected void	onInterruptDetected()
protected Object	resolve(Object value)
ClientMessage	resolveAndThrowIfException(Object response)
protected Throwable	unwrap(Throwable throwable)

Methods inherited from class com.hazelcast.spi.impl.AbstractInvocationFuture

cancel, complete, get, get, getState, isCancelled, isDone, join, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientInvocationFuture

public ClientInvocationFuture(ClientInvocation invocation,
                              Executor internalExecutor,
                              ClientMessage request,
                              ILogger logger,
                              CallIdSequence callIdSequence)

Method Detail

invocationToString

protected String invocationToString()

Specified by:

invocationToString in class AbstractInvocationFuture<ClientMessage>

onInterruptDetected

protected void onInterruptDetected()

Overrides:

onInterruptDetected in class AbstractInvocationFuture<ClientMessage>

newTimeoutException

protected TimeoutException newTimeoutException(long timeout,
                                               TimeUnit unit)

Specified by:

newTimeoutException in class AbstractInvocationFuture<ClientMessage>

unwrap

protected Throwable unwrap(Throwable throwable)

Overrides:

unwrap in class AbstractInvocationFuture<ClientMessage>

resolve

protected Object resolve(Object value)

Overrides:

resolve in class AbstractInvocationFuture<ClientMessage>

andThen

public void andThen(ExecutionCallback<ClientMessage> callback)

Description copied from interface: ICompletableFuture

Registers a callback that will run after this future is completed. If this future is already completed, it runs immediately.

Please note that there is no ordering guarantee for running multiple callbacks. It is also not guaranteed that the callback will run within the same thread that completes the future.

Specified by:

andThen in interface ICompletableFuture<ClientMessage>

Overrides:

andThen in class AbstractInvocationFuture<ClientMessage>

Parameters:

callback - the callback to execute

andThen

public void andThen(ExecutionCallback<ClientMessage> callback,
                    Executor executor)

Description copied from interface: ICompletableFuture

Registers a callback that will run with the provided executor after this future is completed. If this future is already completed, it runs immediately. The callback is called using the given executor. Please note that there is no ordering guarantee for executing multiple callbacks.

Specified by:

andThen in interface ICompletableFuture<ClientMessage>

Overrides:

andThen in class AbstractInvocationFuture<ClientMessage>

Parameters:

callback - the callback to execute

executor - the executor in which the callback will be run

onComplete

protected void onComplete()

Overrides:

onComplete in class AbstractInvocationFuture<ClientMessage>

resolveAndThrowIfException

public ClientMessage resolveAndThrowIfException(Object response)
                                         throws ExecutionException,
                                                InterruptedException

Specified by:

resolveAndThrowIfException in class AbstractInvocationFuture<ClientMessage>

Throws:

ExecutionException

InterruptedException

getInvocation

public ClientInvocation getInvocation()