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

Modifier and Type	Field and Description
protected ClientMessage	request

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

defaultExecutor, logger

Constructor Summary

Constructors

Constructor and Description
ClientInvocationFuture(ClientInvocation invocation, HazelcastClientInstanceImpl client, ClientMessage request, ILogger logger)

Method Summary

Modifier and Type	Method and Description
ClientInvocation	getInvocation()
protected String	invocationToString()
protected TimeoutException	newTimeoutException(long timeout, TimeUnit unit)
protected void	onInterruptDetected()
protected Object	resolve(Object value)
ClientMessage	resolveAndThrow(Object response)
protected Throwable	unwrap(Throwable throwable)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

request

protected final ClientMessage request

Constructor Detail

ClientInvocationFuture

public ClientInvocationFuture(ClientInvocation invocation,
                              HazelcastClientInstanceImpl client,
                              ClientMessage request,
                              ILogger logger)

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>

resolveAndThrow

public ClientMessage resolveAndThrow(Object response)
                              throws ExecutionException,
                                     InterruptedException

Specified by:

resolveAndThrow in class AbstractInvocationFuture<ClientMessage>

Throws:

ExecutionException

InterruptedException

getInvocation

public ClientInvocation getInvocation()