Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
Buffer |
Message.buffer2() |
Buffer |
Message.getBuffer2() |
Modifier and Type | Method and Description |
---|---|
Message |
Message.buffer(Buffer b) |
Message |
Message.setBuffer(Buffer buf)
Sets the buffer
Note that the byte[] buffer passed as argument must not be modified.
|
Constructor and Description |
---|
Message(Address dest,
Buffer buf) |
Modifier and Type | Method and Description |
---|---|
protected static Buffer |
RpcDispatcher.methodCallToBuffer(MethodCall call,
Marshaller marshaller) |
protected static Buffer |
RequestCorrelator.replyToBuffer(Object obj,
Marshaller marshaller) |
Modifier and Type | Method and Description |
---|---|
protected <T> GroupRequest<T> |
MessageDispatcher.cast(Collection<Address> dests,
Buffer data,
RequestOptions options,
boolean block_for_results) |
<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> 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).
|
T |
Request.execute(Buffer data,
boolean block_for_results) |
<T> T |
MessageDispatcher.sendMessage(Address dest,
Buffer data,
RequestOptions opts)
Sends a unicast message and - depending on the options - returns a result
|
<T> CompletableFuture<T> |
MessageDispatcher.sendMessageWithFuture(Address dest,
Buffer data,
RequestOptions opts)
Sends a unicast message to the target defined by msg.getDest() and returns a future
|
void |
GroupRequest.sendRequest(Buffer data) |
void |
UnicastRequest.sendRequest(Buffer data) |
abstract void |
Request.sendRequest(Buffer data) |
protected void |
GroupRequest.sendRequest(Buffer data,
Collection<Address> targetMembers) |
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
|
Modifier and Type | Method and Description |
---|---|
static Buffer |
FD_SOCK.marshal(LazyRemovalCache<Address,IpAddress> addrs) |
static Buffer |
Discovery.marshal(PingData data) |
static Buffer |
MERGE3.marshal(View view) |
protected static Buffer |
COUNTER.requestToBuffer(COUNTER.Request req) |
protected static Buffer |
COUNTER.responseToBuffer(COUNTER.Response rsp) |
protected static Buffer |
COUNTER.streamableToBuffer(byte req_or_rsp,
byte type,
Streamable obj) |
Modifier and Type | Method and Description |
---|---|
protected void |
COUNTER.send(Address dest,
Buffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected static Buffer |
GMS.marshal(Collection<? extends Address> mbrs) |
protected static Buffer |
FLUSH.marshal(Collection<? extends Address> participants,
Digest digest) |
static Buffer |
STABLE.marshal(Digest digest) |
static Buffer |
GMS.marshal(JoinRsp join_rsp) |
protected static Buffer |
GMS.marshal(View view,
Digest digest) |
protected static Buffer |
GMS.marshal(ViewId view_id) |
Modifier and Type | Method and Description |
---|---|
protected void |
GMS.sendJoinResponse(Buffer marshalled_rsp,
Address dest) |
Modifier and Type | Method and Description |
---|---|
Buffer |
Buffer.copy() |
static Buffer |
Util.exceptionToBuffer(Throwable t) |
Buffer |
ByteArrayDataOutputStream.getBuffer() |
Buffer |
ByteBufferOutputStream.getBufferAsBuffer() |
static Buffer |
Util.messageToByteBuffer(Message msg) |
static Buffer |
Util.objectToBuffer(Object obj) |
static Buffer |
Util.streamableToBuffer(Streamable obj) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.