Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.mux |
Modifier and Type | Field and Description |
---|---|
protected RequestOptions |
ReplicatedHashMap.call_options |
protected RequestOptions |
Request.options |
Modifier and Type | Method and Description |
---|---|
static RequestOptions |
RequestOptions.ASYNC() |
RequestOptions |
RequestOptions.clearFlags(Message.Flag... flags) |
RequestOptions |
RequestOptions.clearTransientFlags(Message.TransientFlag... flags) |
RequestOptions |
RequestOptions.setAnycasting(boolean use_anycasting) |
RequestOptions |
RequestOptions.setExclusionList(Address... mbrs) |
RequestOptions |
RequestOptions.setFlags(Message.Flag... flags) |
RequestOptions |
RequestOptions.setMode(ResponseMode mode) |
RequestOptions |
RequestOptions.setRspFilter(RspFilter rsp_filter) |
RequestOptions |
RequestOptions.setScope(short scope) |
RequestOptions |
RequestOptions.setTimeout(long timeout) |
RequestOptions |
RequestOptions.setTransientFlags(Message.TransientFlag... flags) |
static RequestOptions |
RequestOptions.SYNC() |
RequestOptions |
RequestOptions.useAnycastAddresses(boolean flag) |
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,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
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,
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> 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> NotifyingFuture<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> NotifyingFuture<RspList<T>> |
RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests,
MethodCall method_call,
RequestOptions options,
FutureListener<RspList<T>> listener)
Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
|
<T> NotifyingFuture<T> |
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall call,
RequestOptions options)
Invokes a method in a cluster member and - if blocking - returns the result
|
<T> NotifyingFuture<T> |
RpcDispatcher.callRemoteMethodWithFuture(Address dest,
MethodCall call,
RequestOptions options,
FutureListener<T> listener)
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) |
protected <T> GroupRequest<T> |
MessageDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean block_for_results,
FutureListener<RspList<T>> listener) |
<T> RspList<T> |
MessageDispatcher.castMessage(java.util.Collection<Address> dests,
Message msg,
RequestOptions options)
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> NotifyingFuture<RspList<T>> |
MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests,
Message msg,
RequestOptions options)
Sends a message to all members and expects responses from members in dests (if non-null).
|
<T> NotifyingFuture<RspList<T>> |
MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
FutureListener<RspList<T>> listener)
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> NotifyingFuture<T> |
MessageDispatcher.sendMessageWithFuture(Message msg,
RequestOptions options)
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
<T> NotifyingFuture<T> |
MessageDispatcher.sendMessageWithFuture(Message msg,
RequestOptions options,
FutureListener<T> listener)
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
void |
RequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs,
Message msg,
Request req,
RequestOptions options)
Sends a request to a group.
|
Constructor and Description |
---|
GroupRequest(RequestCorrelator corr,
java.util.Collection<Address> targets,
RequestOptions options) |
Request(RequestCorrelator corr,
RequestOptions options) |
RequestOptions(RequestOptions opts) |
UnicastRequest(RequestCorrelator corr,
Address target,
RequestOptions options) |
Modifier and Type | Method and Description |
---|---|
protected <T> GroupRequest<T> |
MuxMessageDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults,
FutureListener<RspList<T>> listener) |
protected <T> GroupRequest<T> |
MuxRpcDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults,
FutureListener<RspList<T>> listener) |
void |
MuxRequestCorrelator.sendRequest(java.util.Collection<Address> dest_mbrs,
Message msg,
Request req,
RequestOptions options) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.