com.hazelcast.client.spi.impl

Class ClientInvocation

java.lang.Object

com.hazelcast.client.spi.impl.ClientInvocation

All Implemented Interfaces:

Runnable

public class ClientInvocation
extends Object
implements Runnable

ClientInvocation handles routing of a request from client

1) Where should request be send 2) Should it be retried 3) How many times it is retried

Field Summary

Fields

Modifier and Type	Field and Description
protected ClientInvocationFuture	clientInvocationFuture
static long	RETRY_WAIT_TIME_IN_SECONDS
protected static int	UNASSIGNED_PARTITION

Constructor Summary

Constructors

Modifier	Constructor and Description
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage)
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Address address)
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Connection connection)
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, int partitionId)
protected	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, int partitionId, Address address, Connection connection)

Method Summary

Methods

Modifier and Type	Method and Description
ClientMessage	getClientMessage()
EventHandler	getEventHandler()
int	getPartitionId()
ClientConnection	getSendConnection()
ClientConnection	getSendConnectionOrWait()
ClientInvocationFuture	invoke()
ClientInvocationFuture	invokeUrgent()
static boolean	isRetryable(Throwable t)
boolean	isUrgent()
void	notify(ClientMessage clientMessage)
void	notifyException(Throwable exception)
void	run()
void	setBypassHeartbeatCheck(boolean bypassHeartbeatCheck)
void	setEventHandler(EventHandler handler)
void	setSendConnection(ClientConnection connection)
boolean	shouldBypassHeartbeatCheck()
protected boolean	shouldRetry()

Methods inherited from class java.lang.Object

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

Field Detail

RETRY_WAIT_TIME_IN_SECONDS

public static final long RETRY_WAIT_TIME_IN_SECONDS

See Also:

Constant Field Values

UNASSIGNED_PARTITION

protected static final int UNASSIGNED_PARTITION

See Also:

Constant Field Values

clientInvocationFuture

protected final ClientInvocationFuture clientInvocationFuture

Constructor Detail

ClientInvocation

protected ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                int partitionId,
                Address address,
                Connection connection)

ClientInvocation

public ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage)

ClientInvocation

public ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                int partitionId)

ClientInvocation

public ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                Address address)

ClientInvocation

public ClientInvocation(HazelcastClientInstanceImpl client,
                ClientMessage clientMessage,
                Connection connection)

Method Detail

getPartitionId

public int getPartitionId()

getClientMessage

public ClientMessage getClientMessage()

invoke

public ClientInvocationFuture invoke()

invokeUrgent

public ClientInvocationFuture invokeUrgent()

run

public void run()

Specified by:

run in interface Runnable

notify

public void notify(ClientMessage clientMessage)

notifyException

public void notifyException(Throwable exception)

shouldRetry

protected boolean shouldRetry()

getEventHandler

public EventHandler getEventHandler()

setEventHandler

public void setEventHandler(EventHandler handler)

shouldBypassHeartbeatCheck

public boolean shouldBypassHeartbeatCheck()

isUrgent

public boolean isUrgent()

setBypassHeartbeatCheck

public void setBypassHeartbeatCheck(boolean bypassHeartbeatCheck)

setSendConnection

public void setSendConnection(ClientConnection connection)

getSendConnectionOrWait

public ClientConnection getSendConnectionOrWait()
                                         throws InterruptedException

Throws:

InterruptedException

getSendConnection

public ClientConnection getSendConnection()

isRetryable

public static boolean isRetryable(Throwable t)