程序包 | 说明 |
---|---|
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.blocks.executor | |
com.fr.third.jgroups.blocks.mux | |
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 字段和说明 |
---|---|
protected FutureListener |
Request.listener |
限定符和类型 | 方法和说明 |
---|---|
<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,
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,
FutureListener<RspList<T>> listener) |
<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> 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
|
NotifyingFuture |
Request.setListener(FutureListener listener) |
限定符和类型 | 类和说明 |
---|---|
protected class |
ExecutionCompletionService.QueueingListener |
限定符和类型 | 方法和说明 |
---|---|
NotifyingFuture<V> |
ExecutionService.DistributedFuture.setListener(FutureListener<V> listener) |
限定符和类型 | 方法和说明 |
---|---|
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) |
限定符和类型 | 方法和说明 |
---|---|
NotifyingFuture |
NullFuture.setListener(FutureListener<T> listener) |
NotifyingFuture |
NotifyingFuture.setListener(FutureListener<T> listener)
Attaches a listener and returns the same future instance, to allow for 'building' futures.
|