Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.tests.perf | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected static RspList |
MessageDispatcher.empty_rsplist |
protected RspList<T> |
GroupRequest.rsps
Correlates requests and responses
|
Modifier and Type | Method and Description |
---|---|
<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> 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).
|
protected RspList<T> |
GroupRequest.doAndComplete(Callable<RspList<T>> supplier) |
RspList<T> |
GroupRequest.get() |
RspList<T> |
GroupRequest.get(long timeout,
TimeUnit unit) |
RspList<T> |
GroupRequest.getNow(RspList<T> valueIfAbsent) |
RspList<T> |
GroupRequest.join() |
RspList<T> |
GroupRequest.waitForCompletion() |
RspList<T> |
GroupRequest.waitForCompletion(long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<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<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).
|
Modifier and Type | Method and Description |
---|---|
RspList<T> |
GroupRequest.getNow(RspList<T> valueIfAbsent) |
Modifier and Type | Method and Description |
---|---|
protected RspList<T> |
GroupRequest.doAndComplete(Callable<RspList<T>> supplier) |
Modifier and Type | Method and Description |
---|---|
protected RspList |
MPerfRpc.invokeRpc(short method_id,
RequestOptions options,
Object... args) |
Modifier and Type | Method and Description |
---|---|
RspList<T> |
RspList.addRsp(Address sender,
T retval) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.