com.hazelcast.client.spi.impl

Class ClientSmartInvocationServiceImpl

java.lang.Object

com.hazelcast.client.spi.impl.ClientSmartInvocationServiceImpl

All Implemented Interfaces:

ClientInvocationService

public final class ClientSmartInvocationServiceImpl
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected HazelcastClientInstanceImpl	client
protected ClientConnectionManager	connectionManager
protected ILogger	invocationLogger
protected ClientPartitionService	partitionService

Constructor Summary

Constructors

Constructor and Description
ClientSmartInvocationServiceImpl(HazelcastClientInstanceImpl client, LoadBalancer loadBalancer)

Method Summary

Modifier and Type	Method and Description
ClientConnection	getConnection(int partitionId)
long	getInvocationTimeoutMillis()
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()

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

invocationLogger

protected final ILogger invocationLogger

connectionManager

protected ClientConnectionManager connectionManager

partitionService

protected ClientPartitionService partitionService

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

getConnection

public ClientConnection getConnection(int partitionId)
                               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

start

public void start()

Specified by:

start in interface ClientInvocationService

isRedoOperation

public boolean isRedoOperation()

Specified by:

isRedoOperation in interface ClientInvocationService

send

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

Throws:

IOException

isShutdown

public boolean isShutdown()

shutdown

public void shutdown()

Specified by:

shutdown in interface ClientInvocationService

handleClientMessage

public void handleClientMessage(ClientMessage message,
                                Connection connection)

Specified by:

handleClientMessage in interface ClientInvocationService

getInvocationTimeoutMillis

public long getInvocationTimeoutMillis()