Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.tests.perf |
Modifier and Type | Field and Description |
---|---|
protected RequestOptions |
ReplicatedHashMap.call_options |
protected RequestOptions |
Request.options |
Modifier and Type | Method and Description |
---|---|
RequestOptions |
RequestOptions.anycasting(boolean a) |
static RequestOptions |
RequestOptions.ASYNC() |
RequestOptions |
RequestOptions.clearFlags(Message.Flag... flags) |
RequestOptions |
RequestOptions.clearTransientFlags(Message.TransientFlag... flags) |
RequestOptions |
RequestOptions.exclusionList(Address... mbrs) |
RequestOptions |
RequestOptions.flags(Message.Flag... flags) |
RequestOptions |
RequestOptions.mode(ResponseMode mode) |
RequestOptions |
RequestOptions.rspFilter(RspFilter filter) |
RequestOptions |
RequestOptions.setAnycasting(boolean a) |
RequestOptions |
RequestOptions.setFlags(Message.Flag... flags) |
RequestOptions |
RequestOptions.setFlags(short flags)
Not recommended as the internal representation of flags might change (e.g.
|
RequestOptions |
RequestOptions.setMode(ResponseMode mode) |
RequestOptions |
RequestOptions.setRspFilter(RspFilter filter) |
RequestOptions |
RequestOptions.setTimeout(long timeout) |
RequestOptions |
RequestOptions.setTransientFlags(Message.TransientFlag... flags) |
RequestOptions |
RequestOptions.setTransientFlags(short flags)
Not recommended as the internal representation of flags might change (e.g.
|
RequestOptions |
RequestOptions.setUseAnycastAddresses(boolean f) |
static RequestOptions |
RequestOptions.SYNC() |
RequestOptions |
RequestOptions.timeout(long timeout) |
RequestOptions |
RequestOptions.transientFlags(Message.TransientFlag... flags) |
RequestOptions |
RequestOptions.useAnycastAddresses(boolean f) |
Modifier and Type | Method and Description |
---|---|
<T> T |
RpcDispatcher.callRemoteMethod(Address dest,
MethodCall call,
RequestOptions options)
Invokes a method in a cluster member and - if blocking - returns the result
|
<T> T |
RpcDispatcher.callRemoteMethod(Address dest,
String meth,
Object[] args,
Class[] types,
RequestOptions opts)
Invokes a method in a cluster member and - if blocking - returns the result
|
<T> RspList<T> |
RpcDispatcher.callRemoteMethods(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> RspList<T> |
RpcDispatcher.callRemoteMethods(Collection<Address> dests,
String method_name,
Object[] args,
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> CompletableFuture<RspList<T>> |
RpcDispatcher.callRemoteMethodsWithFuture(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> 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(Collection<Address> dests,
Buffer data,
RequestOptions options,
boolean block_for_results) |
protected <T> GroupRequest<T> |
MessageDispatcher.cast(Collection<Address> dests,
byte[] data,
int offset,
int length,
RequestOptions options,
boolean block_for_results) |
<T> RspList<T> |
MessageDispatcher.castMessage(Collection<Address> dests,
Buffer data,
RequestOptions opts)
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> RspList<T> |
MessageDispatcher.castMessage(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> CompletableFuture<RspList<T>> |
MessageDispatcher.castMessageWithFuture(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,
Buffer data,
RequestOptions opts)
Sends a unicast message and - depending on the options - returns a result
|
<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> 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
|
<T> 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
|
void |
RequestCorrelator.sendRequest(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
|
Constructor and Description |
---|
GroupRequest(RequestCorrelator corr,
Collection<Address> targets,
RequestOptions options) |
Request(RequestCorrelator corr,
RequestOptions options) |
RequestOptions(RequestOptions opts) |
UnicastRequest(RequestCorrelator corr,
Address target,
RequestOptions options) |
Modifier and Type | Field and Description |
---|---|
protected RequestOptions |
MPerfRpc.send_options |
Modifier and Type | Method and Description |
---|---|
protected Object |
MPerfRpc.invokeRpc(short method_id,
Address dest,
RequestOptions options,
Object... args) |
protected RspList |
MPerfRpc.invokeRpc(short method_id,
RequestOptions options,
Object... args) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.