public final class ClientSmartInvocationServiceImpl extends Object
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ClientListenerServiceImpl |
clientListenerService |
protected ClientConnectionManager |
connectionManager |
protected ClientExecutionService |
executionService |
protected ClientPartitionService |
partitionService |
Constructor and Description |
---|
ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client,
LoadBalancer loadBalancer) |
Modifier and Type | Method and Description |
---|---|
void |
cleanConnectionResources(ClientConnection connection) |
void |
cleanResources(ConstructorFunction<Object,Throwable> responseCtor,
ClientConnection connection) |
void |
connectionAdded(Connection connection) |
void |
connectionRemoved(Connection connection) |
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() |
protected final HazelcastClientInstanceImpl client
protected ClientConnectionManager connectionManager
protected ClientPartitionService partitionService
protected ClientExecutionService executionService
protected ClientListenerServiceImpl clientListenerService
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 void cleanResources(ConstructorFunction<Object,Throwable> responseCtor, ClientConnection connection)
public void connectionAdded(Connection connection)
connectionAdded
in interface ConnectionListener
public void connectionRemoved(Connection connection)
connectionRemoved
in interface ConnectionListener
public void cleanConnectionResources(ClientConnection connection)
cleanConnectionResources
in interface ClientInvocationService
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.