public final class ClientInvocationServiceImpl extends Object implements ClientInvocationService
Constructor and Description |
---|
ClientInvocationServiceImpl(HazelcastClient client) |
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() |
public ClientInvocationServiceImpl(HazelcastClient client)
public <T> ICompletableFuture<T> invokeOnRandomTarget(ClientRequest request) throws Exception
invokeOnRandomTarget
in interface ClientInvocationService
Exception
public <T> ICompletableFuture<T> invokeOnTarget(ClientRequest request, Address target) throws Exception
invokeOnTarget
in interface ClientInvocationService
Exception
public <T> ICompletableFuture<T> invokeOnKeyOwner(ClientRequest request, Object key) throws Exception
invokeOnKeyOwner
in interface ClientInvocationService
Exception
public <T> ICompletableFuture<T> invokeOnRandomTarget(ClientRequest request, EventHandler handler) throws Exception
invokeOnRandomTarget
in interface ClientInvocationService
Exception
public <T> ICompletableFuture<T> invokeOnTarget(ClientRequest request, Address target, EventHandler handler) throws Exception
invokeOnTarget
in interface ClientInvocationService
Exception
public <T> ICompletableFuture<T> invokeOnKeyOwner(ClientRequest request, Object key, EventHandler handler) throws Exception
invokeOnKeyOwner
in interface ClientInvocationService
Exception
public ICompletableFuture send(ClientRequest request, ClientConnection connection)
public Future reSend(ClientCallFuture future) throws Exception
Exception
public void registerFailedListener(ClientCallFuture future)
public void triggerFailedListeners()
public boolean isRedoOperation()
Copyright © 2014 Hazelcast, Inc.. All rights reserved.