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

Handles the routing of a request from a Hazelcast 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
static long	RETRY_WAIT_TIME_IN_SECONDS

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

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

Methods inherited from class java.lang.Object

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

Field Detail

RETRY_WAIT_TIME_IN_SECONDS

public static final long RETRY_WAIT_TIME_IN_SECONDS

See Also:

Constant Field Values

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)

getEventHandler

public EventHandler getEventHandler()

setEventHandler

public void setEventHandler(EventHandler handler)

shouldBypassHeartbeatCheck

public boolean shouldBypassHeartbeatCheck()

setBypassHeartbeatCheck

public void setBypassHeartbeatCheck(boolean bypassHeartbeatCheck)

setSendConnection

public void setSendConnection(ClientConnection connection)

getSendConnectionOrWait

public ClientConnection getSendConnectionOrWait()
                                         throws InterruptedException

Throws:

InterruptedException

getSendConnection

public ClientConnection getSendConnection()

isRetrySafeException

public static boolean isRetrySafeException(Throwable t)

getUserExecutor

public Executor getUserExecutor()

toString

public String toString()

Overrides:

toString in class Object