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) |
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() |
protected ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, int partitionId, Address address, Connection connection)
public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName)
public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, int partitionId)
partitionId
.public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, Address address)
address
.public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, String objectName, Connection connection)
connection
.public int getPartitionId()
public ClientMessage getClientMessage()
public ClientInvocationFuture invoke()
public ClientInvocationFuture invokeUrgent()
public void setInvocationTimeoutMillis(long invocationTimeoutMillis)
public void notify(ClientMessage clientMessage)
public void notifyException(Throwable exception)
public EventHandler getEventHandler()
public void setEventHandler(EventHandler handler)
public void setSendConnection(ClientConnection connection)
public ClientConnection getSendConnectionOrWait() throws InterruptedException
InterruptedException
public ClientConnection getSendConnection()
public static boolean isRetrySafeException(Throwable t)
public Executor getUserExecutor()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.