Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.auth | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.demos.wb |
A distributed whiteboard applet implemented using JGroups.
|
org.jgroups.jmx | |
org.jgroups.mux | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method | Description |
---|---|---|
Message |
Message.copy() |
|
Message |
Message.copy(boolean copy_buffer) |
Create a copy of the message.
|
Message |
Message.makeReply() |
Modifier and Type | Method | Description |
---|---|---|
void |
ExtendedReceiverAdapter.receive(Message msg) |
|
void |
MessageListener.receive(Message msg) |
Called when a message is received.
|
void |
ReceiverAdapter.receive(Message msg) |
|
abstract void |
Channel.send(Message msg) |
Sends a message to a (unicast) destination.
|
void |
JChannel.send(Message msg) |
Sends a message through the protocol stack.
|
void |
Transport.send(Message msg) |
Modifier and Type | Method | Description |
---|---|---|
abstract boolean |
AuthToken.authenticate(AuthToken token,
Message msg) |
This method should be implemented to perform the actual authentication of joining members.
|
boolean |
FixedMembershipToken.authenticate(AuthToken token,
Message msg) |
|
boolean |
MD5Token.authenticate(AuthToken token,
Message msg) |
|
boolean |
SimpleToken.authenticate(AuthToken token,
Message msg) |
|
boolean |
X509Token.authenticate(AuthToken token,
Message msg) |
Modifier and Type | Field | Description |
---|---|---|
protected Message |
GroupRequest.request_msg |
Modifier and Type | Method | Description |
---|---|---|
void |
MessageDispatcher.castMessage(java.util.Vector dests,
long req_id,
Message msg,
RspCollector coll) |
Multicast a message request to all members in
dests and receive responses via the RspCollector
interface. |
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout) |
|
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout,
boolean use_anycasting) |
Cast a message to all members, and wait for
mode responses. |
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout,
boolean use_anycasting,
RspFilter filter) |
|
RspList |
RpcDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout) |
|
java.lang.Object |
MessageDispatcher.handle(Message msg) |
|
java.lang.Object |
RequestHandler.handle(Message msg) |
|
java.lang.Object |
RpcDispatcher.handle(Message req) |
Message contains MethodCall.
|
protected void |
PullPushAdapter.handleMessage(Message msg) |
Deprecated.
Check whether the message has an identifier.
|
protected void |
RequestCorrelator.handleRequest(Message req,
RequestCorrelator.Header hdr) |
Handle a request msg for this correlator
|
void |
DistributedHashtable.receive(Message msg) |
Deprecated.
|
void |
DistributedQueue.receive(Message msg) |
|
void |
DistributedTree.receive(Message msg) |
|
void |
MessageListenerAdapter.receive(Message msg) |
Receive message from group.
|
void |
NotificationBus.receive(Message msg) |
|
void |
ReplicatedHashMap.receive(Message msg) |
|
void |
ReplicatedHashtable.receive(Message msg) |
Deprecated.
|
void |
ReplicatedTree.receive(Message msg) |
Callback.
|
void |
VotingAdapter.receive(Message msg) |
Receive the message.
|
boolean |
RequestCorrelator.receiveMessage(Message msg) |
Handles a message coming from a layer below
|
void |
MessageDispatcher.send(Message msg) |
|
void |
PullPushAdapter.send(java.io.Serializable identifier,
Message msg) |
Deprecated.
Sends a message to the group - listeners to this identifier will receive the messages.
|
void |
PullPushAdapter.send(Message msg) |
Deprecated.
Sends a message with no identifier; listener member will get this message on the other group members.
|
java.lang.Object |
MessageDispatcher.sendMessage(Message msg,
int mode,
long timeout) |
Sends a message to a single member (destination = msg.dest) and returns the response.
|
java.lang.Object |
RpcDispatcher.sendMessage(Message msg,
int mode,
long timeout) |
|
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll) |
|
void |
RequestCorrelator.sendRequest(long id,
java.util.List<Address> dest_mbrs,
Message msg,
RspCollector coll,
boolean use_anycasting) |
Send a request to a group.
|
void |
RequestCorrelator.sendRequest(long id,
Message msg,
RspCollector coll) |
Helper method for
RequestCorrelator.sendRequest(long,List,Message,RspCollector) . |
Constructor | Description |
---|---|
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector<Address> members,
int rsp_mode) |
|
GroupRequest(Message m,
RequestCorrelator corr,
java.util.Vector<Address> members,
int rsp_mode,
long timeout,
int expected_mbrs) |
|
GroupRequest(Message m,
Transport transport,
java.util.Vector<Address> members,
int rsp_mode) |
|
GroupRequest(Message m,
Transport transport,
java.util.Vector<Address> members,
int rsp_mode,
long timeout,
int expected_mbrs) |
Modifier and Type | Method | Description |
---|---|---|
void |
ChatCore.receive(Message msg) |
|
void |
Draw.receive(Message msg) |
|
void |
QuoteServer.receive(Message msg) |
Modifier and Type | Method | Description |
---|---|---|
void |
Whiteboard.receive(Message m) |
Modifier and Type | Method | Description |
---|---|---|
void |
JChannel.send(Message msg) |
|
void |
JChannelMBean.send(Message msg) |
Modifier and Type | Method | Description |
---|---|---|
void |
MuxChannel.send(Message msg) |
Modifier and Type | Method | Description |
---|---|---|
Message |
TransportedVectorTime.getAssociatedMessage() |
Returns a message associated with this vector timestamp.
|
Modifier and Type | Method | Description |
---|---|---|
void |
BasicTCP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
LOOPBACK.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
SHARED_LOOPBACK.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
abstract void |
TP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
TUNNEL.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
UDP.postUnmarshalling(Message msg,
Address dest,
Address src,
boolean multicast) |
|
void |
BasicTCP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
LOOPBACK.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
SHARED_LOOPBACK.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
abstract void |
TP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
TUNNEL.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
UDP.postUnmarshallingList(Message msg,
Address dest,
boolean multicast) |
|
void |
SMACK.retransmit(long seqno,
Message msg,
Address dest) |
|
void |
UNICAST.retransmit(long seqno,
Message msg) |
Called by AckSenderWindow to resend messages for which no ACK has been received yet
|
protected void |
JMS.sendMessage(Message msg) |
Publish message in the JMS topic.
|
void |
TransportedVectorTime.setAssociatedMessage(Message owner) |
Sets a message associated with this vector timestamp
|
Modifier and Type | Field | Description |
---|---|---|
static Message |
NakReceiverWindow.NULL_MSG |
dummy for null values: ConcurrentHashMap doesn't allow null values
|
Modifier and Type | Method | Description |
---|---|---|
Message |
NakReceiverWindow.get(long seqno) |
Returns the message from xmit_table
|
Message |
AckSenderWindow.getLowestMessage() |
Returns the message with the lowest seqno
|
Message |
AckReceiverWindow.remove() |
Removes a message whose seqno is equal to
next_to_remove , increments the latter. |
Message |
NakReceiverWindow.remove() |
|
Message |
AckReceiverWindow.removeOOBMessage() |
|
Message |
NakReceiverWindow.removeOOBMessage() |
Modifier and Type | Method | Description |
---|---|---|
void |
AckMcastSenderWindow.add(long seqno,
Message msg,
java.util.Vector receivers) |
Adds a new message to the hash table.
|
boolean |
AckReceiverWindow.add(long seqno,
Message msg) |
Adds a new message.
|
void |
AckSenderWindow.add(long seqno,
Message msg) |
Adds a new message to the retransmission table.
|
boolean |
NakReceiverWindow.add(long seqno,
Message msg) |
Adds a message according to its seqno (sequence number).
|
void |
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg,
Address dest) |
Retranmit the given msg
|
void |
AckSenderWindow.RetransmitCommand.retransmit(long seqno,
Message msg) |
|
void |
ProtocolStack.send(Message msg) |
Modifier and Type | Method | Description |
---|---|---|
static Message |
Util.byteBufferToMessage(byte[] buffer,
int offset,
int length) |
Modifier and Type | Method | Description |
---|---|---|
static java.util.List<Message> |
Util.byteBufferToMessageList(byte[] buffer,
int offset,
int length) |
Modifier and Type | Method | Description |
---|---|---|
static Buffer |
Util.messageToByteBuffer(Message msg) |
|
static java.lang.String |
Util.printMessage(Message msg) |
Tries to read an object from the message's buffer and prints it
|
static java.lang.String |
Util.printMethodCall(Message msg) |
Tries to read a
MethodCall object from the message's buffer and prints it. |
Modifier and Type | Method | Description |
---|---|---|
static Buffer |
Util.msgListToByteBuffer(java.util.List<Message> xmit_list) |
Marshalls a list of messages.
|
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.