程序包 | 说明 |
---|---|
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.blocks.mux |
限定符和类型 | 类和说明 |
---|---|
class |
GroupRequest<T>
Sends a message to all members of the group and waits for all responses (or
timeout).
|
class |
Request
Abstract class for a unicast or multicast request
|
class |
UnicastRequest<T>
Sends a request to a single target destination
|
限定符和类型 | 字段和说明 |
---|---|
protected java.util.concurrent.ConcurrentMap<java.lang.Long,RspCollector> |
RequestCorrelator.requests
The table of pending requests (keys=Long (request IDs), values=RequestEntry)
|
限定符和类型 | 方法和说明 |
---|---|
void |
RequestCorrelator.sendRequest(long id,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options)
Sends a request to a group.
|
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll) |
void |
RequestCorrelator.sendUnicastRequest(long id,
Address target,
Message msg,
RspCollector coll)
Sends a request to a single destination
|
限定符和类型 | 方法和说明 |
---|---|
void |
MuxRequestCorrelator.sendRequest(long requestId,
java.util.Collection<Address> dest_mbrs,
Message msg,
RspCollector coll,
RequestOptions options) |
void |
MuxRequestCorrelator.sendUnicastRequest(long id,
Address target,
Message msg,
RspCollector coll) |