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

Constructors

Constructor and Description
ClientInvocationServiceImpl(HazelcastClient client)

Method Summary

Modifier and Type	Method and Description
String	deRegisterListener(String alias)
<T> ICompletableFuture<T>	invokeOnKeyOwner(ClientRequest request, Object key)
<T> ICompletableFuture<T>	invokeOnKeyOwner(ClientRequest request, Object key, EventHandler handler)
<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()
void	registerFailedListener(ClientCallFuture future)
void	registerListener(String uuid, Integer callId)
void	reRegisterListener(String uuid, String alias, Integer callId)
Future	reSend(ClientCallFuture future)
ICompletableFuture	send(ClientRequest request, ClientConnection connection)
void	triggerFailedListeners()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientInvocationServiceImpl

public ClientInvocationServiceImpl(HazelcastClient 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

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

invokeOnKeyOwner

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

Specified by:

invokeOnKeyOwner in interface ClientInvocationService

Throws:

Exception

send

public ICompletableFuture send(ClientRequest request,
                               ClientConnection connection)

reSend

public Future reSend(ClientCallFuture future)
              throws Exception

Throws:

Exception

registerFailedListener

public void registerFailedListener(ClientCallFuture future)

triggerFailedListeners

public void triggerFailedListeners()

registerListener

public void registerListener(String uuid,
                             Integer callId)

reRegisterListener

public void reRegisterListener(String uuid,
                               String alias,
                               Integer callId)

isRedoOperation

public boolean isRedoOperation()

deRegisterListener

public String deRegisterListener(String alias)