public abstract class AbstractClientInvocationService extends Object implements ClientInvocationService
Modifier and Type | Field and Description |
---|---|
protected HazelcastClientInstanceImpl |
client |
protected ClientConnectionManager |
connectionManager |
protected ClientPartitionService |
partitionService |
Constructor and Description |
---|
AbstractClientInvocationService(HazelcastClientInstanceImpl client) |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
invokeOnConnection, invokeOnPartitionOwner, invokeOnRandomTarget, invokeOnTarget
protected final HazelcastClientInstanceImpl client
protected ClientConnectionManager connectionManager
protected ClientPartitionService partitionService
public AbstractClientInvocationService(HazelcastClientInstanceImpl client)
public long concurrentInvocations()
concurrentInvocations
in interface ClientInvocationService
public long getInvocationTimeoutMillis()
public long getInvocationRetryPauseMillis()
public void start()
public Consumer<ClientMessage> getResponseHandler()
getResponseHandler
in interface ClientInvocationService
public boolean isRedoOperation()
isRedoOperation
in interface ClientInvocationService
protected void send(ClientInvocation invocation, ClientConnection connection) throws IOException
IOException
public boolean isShutdown()
public void shutdown()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.