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 sent?
2) Should it be retried?
3) How many times is it retried?

Constructor Summary

Constructors

Modifier	Constructor and Description
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName) Create an invocation that will be executed on random member.
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, Address address) Create an invocation that will be executed on member with given address.
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, Connection connection) Create an invocation that will be executed on given connection.
	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, int partitionId) Create an invocation that will be executed on owner of partitionId.
protected	ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, 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	setEventHandler(EventHandler handler)
void	setInvocationTimeoutMillis(long invocationTimeoutMillis)
void	setSendConnection(ClientConnection connection)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientInvocation

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

ClientInvocation

public ClientInvocation(HazelcastClientInstanceImpl client,
                        ClientMessage clientMessage,
                        String objectName)

Create an invocation that will be executed on random member.

ClientInvocation

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

Create an invocation that will be executed on owner of partitionId.

ClientInvocation

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

Create an invocation that will be executed on member with given address.

ClientInvocation

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

Create an invocation that will be executed on given 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

setInvocationTimeoutMillis

public void setInvocationTimeoutMillis(long invocationTimeoutMillis)

notify

public void notify(ClientMessage clientMessage)

notifyException

public void notifyException(Throwable exception)

getEventHandler

public EventHandler getEventHandler()

setEventHandler

public void setEventHandler(EventHandler handler)

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