程序包 | 说明 |
---|---|
com.fr.cluster.engine.transport.context | |
com.fr.cluster.engine.transport.context.impl | |
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.blocks.mux | |
com.fr.third.jgroups.tests.perf |
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<ClusterNode,ClusterMessage> |
ClusterMessageSender.cast(ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options)
对特定接受者广播消息
|
void |
ClusterMessageSender.cast(ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options,
ClusterMessageSender.CastCallback castCallback)
异步广播
|
ClusterMessage |
ClusterMessageSender.send(ClusterNode node,
ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options)
指定节点和接收者发送消息
|
void |
ClusterMessageSender.send(ClusterNode address,
ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options,
ClusterMessageSender.Callback callback)
异步发送
|
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<ClusterNode,ClusterMessage> |
FineClusterMessageSender.cast(ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options) |
void |
FineClusterMessageSender.cast(ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options,
ClusterMessageSender.CastCallback castCallback) |
ClusterMessage |
FineClusterMessageSender.send(ClusterNode node,
ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options) |
void |
FineClusterMessageSender.send(ClusterNode address,
ClusterMessageReceiver receiver,
ClusterMessage message,
RequestOptions options,
ClusterMessageSender.Callback callback) |
限定符和类型 | 字段和说明 |
---|---|
protected RequestOptions |
ReplicatedHashMap.call_options |
protected RequestOptions |
Request.options |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
<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(long id,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options)
Sends a request to a group.
|
构造器和说明 |
---|
GroupRequest(Message msg,
RequestCorrelator corr,
Address target,
RequestOptions options) |
GroupRequest(Message msg,
RequestCorrelator corr,
java.util.Collection<Address> targets,
RequestOptions options) |
Request(Message request,
RequestCorrelator corr,
RequestOptions options) |
RequestOptions(RequestOptions opts) |
UnicastRequest(Message msg,
Address target,
RequestOptions options) |
UnicastRequest(Message msg,
RequestCorrelator corr,
Address target,
RequestOptions options) |
限定符和类型 | 方法和说明 |
---|---|
protected <T> GroupRequest<T> |
MuxRpcDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults,
FutureListener<RspList<T>> listener) |
protected <T> GroupRequest<T> |
MuxMessageDispatcher.cast(java.util.Collection<Address> dests,
Message msg,
RequestOptions options,
boolean blockForResults,
FutureListener<RspList<T>> listener) |
void |
MuxRequestCorrelator.sendRequest(long requestId,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options) |
限定符和类型 | 字段和说明 |
---|---|
protected RequestOptions |
MPerfRpc.send_options |
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
MPerfRpc.invokeRpc(short method_id,
Address dest,
RequestOptions options,
java.lang.Object... args) |
protected RspList |
MPerfRpc.invokeRpc(short method_id,
RequestOptions options,
java.lang.Object... args) |