protected <T> UnicastRequest<T> |
MessageDispatcher._sendMessage(Message msg,
RequestOptions opts) |
|
<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 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,
Message msg,
RequestOptions options,
boolean block_for_results) |
|
<T> RspList<T> |
MessageDispatcher.castMessage(java.util.Collection<Address> dests,
Message msg,
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,
Message msg,
RequestOptions opts) |
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> T |
MessageDispatcher.sendMessage(Message msg,
RequestOptions opts) |
Sends a unicast message and - depending on the options - returns a result
|
<T> java.util.concurrent.CompletableFuture<T> |
MessageDispatcher.sendMessageWithFuture(Message msg,
RequestOptions opts) |
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
<T> void |
RequestCorrelator.sendMulticastRequest(java.util.Collection<Address> dest_mbrs,
Message msg,
Request<T> req,
RequestOptions opts) |
Sends a request to a group.
|
<T> void |
RequestCorrelator.sendUnicastRequest(Message msg,
Request<T> req,
RequestOptions opts) |
Sends a request to a single destination
|