public final class ClientSmartInvocationServiceImpl extends Object
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ClientListenerServiceImpl |
clientListenerService |
protected ClientConnectionManager |
connectionManager |
protected ClientExecutionService |
executionService |
static HazelcastProperty |
IDLE_STRATEGY |
protected ILogger |
invocationLogger |
protected ClientPartitionService |
partitionService |
Constructor and Description |
---|
ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client,
LoadBalancer loadBalancer) |
Modifier and Type | Method and Description |
---|---|
void |
handleClientMessage(ClientMessage message,
Connection connection) |
void |
invokeOnConnection(ClientInvocation invocation,
ClientConnection connection) |
void |
invokeOnPartitionOwner(ClientInvocation invocation,
int partitionId) |
void |
invokeOnRandomTarget(ClientInvocation invocation) |
void |
invokeOnTarget(ClientInvocation invocation,
Address target) |
boolean |
isRedoOperation() |
boolean |
isShutdown() |
protected void |
send(ClientInvocation invocation,
ClientConnection connection) |
void |
shutdown() |
void |
start() |
public static final HazelcastProperty IDLE_STRATEGY
protected final HazelcastClientInstanceImpl client
protected ClientConnectionManager connectionManager
protected ClientPartitionService partitionService
protected ClientExecutionService executionService
protected ClientListenerServiceImpl clientListenerService
protected final ILogger invocationLogger
public ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client, LoadBalancer loadBalancer)
public void invokeOnPartitionOwner(ClientInvocation invocation, int partitionId) throws IOException
IOException
public void invokeOnRandomTarget(ClientInvocation invocation) throws IOException
IOException
public void invokeOnTarget(ClientInvocation invocation, Address target) throws IOException
IOException
public void invokeOnConnection(ClientInvocation invocation, ClientConnection connection) throws IOException
IOException
public void start()
start
in interface ClientInvocationService
public boolean isRedoOperation()
isRedoOperation
in interface ClientInvocationService
protected void send(ClientInvocation invocation, ClientConnection connection) throws IOException
IOException
public boolean isShutdown()
public void shutdown()
shutdown
in interface ClientInvocationService
public void handleClientMessage(ClientMessage message, Connection connection)
handleClientMessage
in interface ClientInvocationService
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.