com.hazelcast.client.spi.impl

Class ClientSmartInvocationServiceImpl

java.lang.Object

com.hazelcast.client.spi.impl.ClientSmartInvocationServiceImpl

All Implemented Interfaces:

ClientInvocationService, ConnectionHeartbeatListener, ConnectionListener

public final class ClientSmartInvocationServiceImpl
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected HazelcastClientInstanceImpl	client
protected ClientConnectionManager	connectionManager
protected ClientExecutionService	executionService
protected ClientPartitionService	partitionService

Constructor Summary

Constructors

Constructor and Description
ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client, LoadBalancer loadBalancer)

Method Summary

Methods

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)
EventHandler	getEventHandler(int callId)
void	handlePacket(Packet packet)
void	heartBeatStarted(Connection connection)
void	heartBeatStopped(Connection connection)
void	invokeOnConnection(ClientInvocation invocation, ClientConnection connection)
void	invokeOnPartitionOwner(ClientInvocation invocation, int partitionId)
void	invokeOnRandomTarget(ClientInvocation invocation)
void	invokeOnTarget(ClientInvocation invocation, Address target)
<T> ICompletableFuture<T>	invokeOnTarget(ClientRequest request, Address target)
boolean	isRedoOperation()
boolean	isShutdown()
boolean	removeEventHandler(Integer callId) Removes event handler corresponding to callId
protected void	send(ClientInvocation invocation, ClientConnection connection)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

client

protected final HazelcastClientInstanceImpl client

connectionManager

protected final ClientConnectionManager connectionManager

partitionService

protected final ClientPartitionService partitionService

executionService

protected final ClientExecutionService executionService

Constructor Detail

ClientSmartInvocationServiceImpl

public ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client,
                                LoadBalancer loadBalancer)

Method Detail

invokeOnPartitionOwner

public void invokeOnPartitionOwner(ClientInvocation invocation,
                          int partitionId)
                            throws IOException

Throws:

IOException

invokeOnRandomTarget

public void invokeOnRandomTarget(ClientInvocation invocation)
                          throws IOException

Throws:

IOException

invokeOnTarget

public void invokeOnTarget(ClientInvocation invocation,
                  Address target)
                    throws IOException

Throws:

IOException

invokeOnConnection

public void invokeOnConnection(ClientInvocation invocation,
                      ClientConnection connection)
                        throws IOException

Throws:

IOException

invokeOnTarget

public <T> ICompletableFuture<T> invokeOnTarget(ClientRequest request,
                                       Address target)
                                     throws Exception

Specified by:

invokeOnTarget in interface ClientInvocationService

Throws:

Exception

isRedoOperation

public boolean isRedoOperation()

Specified by:

isRedoOperation in interface ClientInvocationService

send

protected void send(ClientInvocation invocation,
        ClientConnection connection)
             throws IOException

Throws:

IOException

getEventHandler

public EventHandler getEventHandler(int callId)

Specified by:

getEventHandler in interface ClientInvocationService

removeEventHandler

public boolean removeEventHandler(Integer callId)

Description copied from interface: ClientInvocationService

Removes event handler corresponding to callId

Specified by:

removeEventHandler in interface ClientInvocationService

Parameters:

callId - of event handler registration request

Returns:

true if found and removed, false otherwise

cleanResources

public void cleanResources(ConstructorFunction<Object,Throwable> responseCtor,
                  ClientConnection connection)

heartBeatStarted

public void heartBeatStarted(Connection connection)

Specified by:

heartBeatStarted in interface ConnectionHeartbeatListener

heartBeatStopped

public void heartBeatStopped(Connection connection)

Specified by:

heartBeatStopped in interface ConnectionHeartbeatListener

connectionAdded

public void connectionAdded(Connection connection)

Specified by:

connectionAdded in interface ConnectionListener

connectionRemoved

public void connectionRemoved(Connection connection)

Specified by:

connectionRemoved in interface ConnectionListener

cleanConnectionResources

public void cleanConnectionResources(ClientConnection connection)

Specified by:

cleanConnectionResources in interface ClientInvocationService

isShutdown

public boolean isShutdown()

shutdown

public void shutdown()

Specified by:

shutdown in interface ClientInvocationService

handlePacket

public void handlePacket(Packet packet)

Specified by:

handlePacket in interface ClientInvocationService