com.hazelcast.client.spi.impl
Class ClientInvocationServiceImpl

java.lang.Object
  com.hazelcast.client.spi.impl.ClientInvocationServiceImpl

All Implemented Interfaces:

ClientInvocationService

public final class ClientInvocationServiceImpl
extends Object
implements ClientInvocationService

Constructor Summary

ClientInvocationServiceImpl(HazelcastClientInstanceImpl client)

Method Summary

void	handlePacket(Packet packet)
<T> ICompletableFuture<T>	invokeOnKeyOwner(ClientRequest request, Object key)
<T> ICompletableFuture<T>	invokeOnKeyOwner(ClientRequest request, Object key, EventHandler handler)
<T> ICompletableFuture<T>	invokeOnPartitionOwner(ClientRequest request, int partitionId)
<T> ICompletableFuture<T>	invokeOnRandomTarget(ClientRequest request)
<T> ICompletableFuture<T>	invokeOnRandomTarget(ClientRequest request, EventHandler handler)
<T> ICompletableFuture<T>	invokeOnTarget(ClientRequest request, Address target)
<T> ICompletableFuture<T>	invokeOnTarget(ClientRequest request, Address target, EventHandler handler)
boolean	isRedoOperation()
Future	reSend(ClientCallFuture future)
ICompletableFuture	send(ClientRequest request, ClientConnection connection)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientInvocationServiceImpl

public ClientInvocationServiceImpl(HazelcastClientInstanceImpl client)

Method Detail

invokeOnRandomTarget

public <T> ICompletableFuture<T> invokeOnRandomTarget(ClientRequest request)
                                           throws Exception

Specified by:

invokeOnRandomTarget in interface ClientInvocationService

Throws:

Exception

invokeOnTarget

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

Specified by:

invokeOnTarget in interface ClientInvocationService

Throws:

Exception

invokeOnKeyOwner

public <T> ICompletableFuture<T> invokeOnKeyOwner(ClientRequest request,
                                                  Object key)
                                       throws Exception

Specified by:

invokeOnKeyOwner in interface ClientInvocationService

Throws:

Exception

invokeOnKeyOwner

public <T> ICompletableFuture<T> invokeOnKeyOwner(ClientRequest request,
                                                  Object key,
                                                  EventHandler handler)
                                       throws Exception

Specified by:

invokeOnKeyOwner in interface ClientInvocationService

Throws:

Exception

invokeOnPartitionOwner

public <T> ICompletableFuture<T> invokeOnPartitionOwner(ClientRequest request,
                                                        int partitionId)
                                             throws Exception

Specified by:

invokeOnPartitionOwner in interface ClientInvocationService

Throws:

Exception

invokeOnRandomTarget

public <T> ICompletableFuture<T> invokeOnRandomTarget(ClientRequest request,
                                                      EventHandler handler)
                                           throws Exception

Specified by:

invokeOnRandomTarget in interface ClientInvocationService

Throws:

Exception

invokeOnTarget

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

Specified by:

invokeOnTarget in interface ClientInvocationService

Throws:

Exception

send

public ICompletableFuture send(ClientRequest request,
                               ClientConnection connection)

reSend

public Future reSend(ClientCallFuture future)
              throws Exception

Throws:

Exception

isRedoOperation

public boolean isRedoOperation()

shutdown

public void shutdown()

handlePacket

public void handlePacket(Packet packet)