Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
Modifier and Type | Class and Description |
---|---|
class |
GroupRequest<T>
Sends a message to all members of the group and waits for all responses (or timeout).
|
class |
UnicastRequest<T>
Sends a request to a single target destination
|
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Long,Request> |
RequestCorrelator.requests
The table of pending requests (keys=Long (request IDs), values=RequestEntry)
|
Modifier and Type | Method and Description |
---|---|
Request<T> |
Request.requestId(long req_id) |
Request |
Request.setResponseFilter(RspFilter filter) |
Modifier and Type | Method and Description |
---|---|
protected void |
RequestCorrelator.handleResponse(Request req,
Address sender,
byte[] buf,
int offset,
int length,
boolean is_exception) |
void |
RequestCorrelator.sendRequest(Collection<Address> dest_mbrs,
Buffer data,
Request req,
RequestOptions opts)
Sends a request to a group.
|
void |
RequestCorrelator.sendUnicastRequest(Address dest,
Buffer data,
Request req,
RequestOptions opts)
Sends a request to a single destination
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.