<T> T |
RpcDispatcher.callRemoteMethod(Address dest,
java.lang.String meth,
java.lang.Object[] args,
java.lang.Class[] types,
RequestOptions opts) |
Invokes a method in a cluster member and - if blocking - returns the result
|
<T> T |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall call,
RequestOptions options) |
Invokes a method in a cluster member and - if blocking - returns the result
|
<T> RspList<T> |
RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
RequestOptions options) |
Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
|
<T> RspList<T> |
RpcDispatcher.callRemoteMethods(java.util.Collection<Address> dests,
MethodCall method_call,
RequestOptions opts) |
Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
|
<T> java.util.concurrent.CompletableFuture<RspList<T>> |
RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests,
MethodCall method_call,
RequestOptions options) |
Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
|
<T> java.util.concurrent.CompletableFuture<T> |
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall call,
RequestOptions opts) |
Invokes a method in a cluster member and - if blocking - returns the result
|
protected <T> GroupRequest<T> |
MessageDispatcher.cast(java.util.Collection<Address> dests,
byte[] data,
int offset,
int length,
RequestOptions options,
boolean block_for_results) |
|
protected <T> GroupRequest<T> |
MessageDispatcher.cast(java.util.Collection<Address> dests,
Buffer data,
RequestOptions options,
boolean block_for_results) |
|
<T> RspList<T> |
MessageDispatcher.castMessage(java.util.Collection<Address> dests,
byte[] data,
int offset,
int length,
RequestOptions opts) |
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> RspList<T> |
MessageDispatcher.castMessage(java.util.Collection<Address> dests,
Buffer data,
RequestOptions opts) |
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> java.util.concurrent.CompletableFuture<RspList<T>> |
MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests,
Buffer data,
RequestOptions opts) |
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> T |
MessageDispatcher.sendMessage(Address dest,
byte[] data,
int offset,
int length,
RequestOptions opts) |
Sends a unicast message and - depending on the options - returns a result
|
<T> T |
MessageDispatcher.sendMessage(Address dest,
Buffer data,
RequestOptions opts) |
Sends a unicast message and - depending on the options - returns a result
|
<T> java.util.concurrent.CompletableFuture<T> |
MessageDispatcher.sendMessageWithFuture(Address dest,
byte[] data,
int offset,
int length,
RequestOptions opts) |
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
<T> java.util.concurrent.CompletableFuture<T> |
MessageDispatcher.sendMessageWithFuture(Address dest,
Buffer data,
RequestOptions opts) |
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
void |
RequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs,
Buffer data,
Request req,
RequestOptions opts) |
Sends a request to a group.
|
void |
RequestCorrelator.sendUnicastRequest(Address dest,
Buffer data,
Request req,
RequestOptions opts) |
Sends a request to a single destination
|