com.hazelcast.client.spi.impl
public final class ClientSmartInvocationServiceImpl extends Object
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ClientConnectionManager |
connectionManager |
protected ClientExecutionService |
executionService |
protected ClientPartitionService |
partitionService |
Constructor and Description |
---|
ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client,
LoadBalancer loadBalancer) |
protected final HazelcastClientInstanceImpl client
protected final ClientConnectionManager connectionManager
protected final ClientPartitionService partitionService
protected final ClientExecutionService executionService
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 <T> ICompletableFuture<T> invokeOnTarget(ClientRequest request, Address target) throws Exception
invokeOnTarget
in interface ClientInvocationService
Exception
public boolean isRedoOperation()
isRedoOperation
in interface ClientInvocationService
protected void send(ClientInvocation invocation, ClientConnection connection) throws IOException
IOException
public EventHandler getEventHandler(int callId)
getEventHandler
in interface ClientInvocationService
public boolean removeEventHandler(Integer callId)
ClientInvocationService
removeEventHandler
in interface ClientInvocationService
callId
- of event handler registration requestpublic void cleanResources(ConstructorFunction<Object,Throwable> responseCtor, ClientConnection connection)
public void heartBeatStarted(Connection connection)
heartBeatStarted
in interface ConnectionHeartbeatListener
public void heartBeatStopped(Connection connection)
heartBeatStopped
in interface ConnectionHeartbeatListener
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 handlePacket(Packet packet)
handlePacket
in interface ClientInvocationService
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.