public class ClientInvocation extends BaseInvocation implements Runnable
1) Where should request be sent?
2) Should it be retried?
3) How many times is it retried?
backupsAcksReceived
Modifier | Constructor and Description |
---|---|
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName)
Create an invocation that will be executed on random member.
|
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
Address address)
Create an invocation that will be executed on member with given
address . |
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
Connection connection)
Create an invocation that will be executed on given
connection . |
|
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
int partitionId)
Create an invocation that will be executed on owner of
partitionId . |
protected |
ClientInvocation(HazelcastClientInstanceImpl client,
ClientMessage clientMessage,
Object objectName,
int partitionId,
Address address,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected void |
complete(Object response) |
protected void |
completeExceptionally(Throwable t) |
ClientMessage |
getClientMessage() |
int |
getPartitionId() |
ClientConnection |
getSendConnection() |
ClientConnection |
getSendConnectionOrWait() |
Executor |
getUserExecutor() |
ClientInvocationFuture |
invoke() |
ClientInvocationFuture |
invokeUrgent() |
static boolean |
isRetrySafeException(Throwable t) |
void |
run() |
void |
setEventHandler(EventHandler handler) |
void |
setInvocationTimeoutMillis(long invocationTimeoutMillis) |
void |
setSendConnection(ClientConnection connection) |
protected boolean |
shouldCompleteWithoutBackups() |
protected boolean |
shouldFailOnIndeterminateOperationState() |
String |
toString() |
detectAndHandleBackupTimeout, notifyBackupComplete, notifyResponse
protected ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Object objectName, int partitionId, Address address, Connection connection)
public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Object objectName)
public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Object objectName, int partitionId)
partitionId
.public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Object objectName, Address address)
address
.public ClientInvocation(HazelcastClientInstanceImpl client, ClientMessage clientMessage, Object objectName, Connection connection)
connection
.public int getPartitionId()
public ClientMessage getClientMessage()
public ClientInvocationFuture invoke()
public ClientInvocationFuture invokeUrgent()
public void setInvocationTimeoutMillis(long invocationTimeoutMillis)
protected boolean shouldCompleteWithoutBackups()
shouldCompleteWithoutBackups
in class BaseInvocation
protected void complete(Object response)
complete
in class BaseInvocation
protected void completeExceptionally(Throwable t)
completeExceptionally
in class BaseInvocation
protected boolean shouldFailOnIndeterminateOperationState()
shouldFailOnIndeterminateOperationState
in class BaseInvocation
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.