com.hazelcast.client.spi.impl

Class AbstractClientInvocationService

java.lang.Object

com.hazelcast.client.spi.impl.AbstractClientInvocationService

All Implemented Interfaces:

ClientInvocationService

Direct Known Subclasses:

NonSmartClientInvocationService, SmartClientInvocationService

public abstract class AbstractClientInvocationService
extends Object
implements ClientInvocationService

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractClientInvocationService(HazelcastClientInstanceImpl client)

Method Summary

Modifier and Type	Method and Description
long	concurrentInvocations()
long	getInvocationRetryPauseMillis()
long	getInvocationTimeoutMillis()
Consumer<ClientMessage>	getResponseHandler()
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

Methods inherited from interface com.hazelcast.client.spi.ClientInvocationService

invokeOnConnection, invokeOnPartitionOwner, invokeOnRandomTarget, invokeOnTarget

Field Detail

client

protected final HazelcastClientInstanceImpl client

connectionManager

protected ClientConnectionManager connectionManager

partitionService

protected ClientPartitionService partitionService

Constructor Detail

AbstractClientInvocationService

public AbstractClientInvocationService(HazelcastClientInstanceImpl client)

Method Detail

concurrentInvocations

public long concurrentInvocations()

Specified by:

concurrentInvocations in interface ClientInvocationService

getInvocationTimeoutMillis

public long getInvocationTimeoutMillis()

getInvocationRetryPauseMillis

public long getInvocationRetryPauseMillis()

start

public void start()

getResponseHandler

public Consumer<ClientMessage> getResponseHandler()

Specified by:

getResponseHandler 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()