Uses of Class
org.jgroups.Message
-
Packages that use Message 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. -
-
Uses of Message in org.jgroups
Methods in org.jgroups that return Message Modifier and Type Method Description Message
Message. copy()
Message
Message. copy(boolean copy_buffer)
Create a copy of the message.Message
Message. makeReply()
Methods in org.jgroups with parameters of type Message 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)
-
Uses of Message in org.jgroups.auth
Methods in org.jgroups.auth with parameters of type Message 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)
-
Uses of Message in org.jgroups.blocks
Fields in org.jgroups.blocks declared as Message Modifier and Type Field Description protected Message
GroupRequest. request_msg
Methods in org.jgroups.blocks with parameters of type Message 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 indests
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 formode
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 correlatorvoid
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 belowvoid
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 forRequestCorrelator.sendRequest(long,List,Message,RspCollector)
.Constructors in org.jgroups.blocks with parameters of type Message 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)
-
Uses of Message in org.jgroups.demos
Methods in org.jgroups.demos with parameters of type Message Modifier and Type Method Description void
ChatCore. receive(Message msg)
void
Draw. receive(Message msg)
void
QuoteServer. receive(Message msg)
-
Uses of Message in org.jgroups.demos.wb
Methods in org.jgroups.demos.wb with parameters of type Message Modifier and Type Method Description void
Whiteboard. receive(Message m)
-
Uses of Message in org.jgroups.jmx
Methods in org.jgroups.jmx with parameters of type Message Modifier and Type Method Description void
JChannel. send(Message msg)
void
JChannelMBean. send(Message msg)
-
Uses of Message in org.jgroups.mux
Methods in org.jgroups.mux with parameters of type Message Modifier and Type Method Description void
MuxChannel. send(Message msg)
-
Uses of Message in org.jgroups.protocols
Methods in org.jgroups.protocols that return Message Modifier and Type Method Description Message
TransportedVectorTime. getAssociatedMessage()
Returns a message associated with this vector timestamp.Methods in org.jgroups.protocols with parameters of type Message 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 yetprotected void
JMS. sendMessage(Message msg)
Publish message in the JMS topic.void
TransportedVectorTime. setAssociatedMessage(Message owner)
Sets a message associated with this vector timestamp -
Uses of Message in org.jgroups.stack
Fields in org.jgroups.stack declared as Message Modifier and Type Field Description static Message
NakReceiverWindow. NULL_MSG
dummy for null values: ConcurrentHashMap doesn't allow null valuesMethods in org.jgroups.stack that return Message Modifier and Type Method Description Message
NakReceiverWindow. get(long seqno)
Returns the message from xmit_tableMessage
AckSenderWindow. getLowestMessage()
Returns the message with the lowest seqnoMessage
AckReceiverWindow. remove()
Removes a message whose seqno is equal tonext_to_remove
, increments the latter.Message
NakReceiverWindow. remove()
Message
AckReceiverWindow. removeOOBMessage()
Message
NakReceiverWindow. removeOOBMessage()
Methods in org.jgroups.stack with parameters of type Message 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 msgvoid
AckSenderWindow.RetransmitCommand. retransmit(long seqno, Message msg)
void
ProtocolStack. send(Message msg)
-
Uses of Message in org.jgroups.util
Methods in org.jgroups.util that return Message Modifier and Type Method Description static Message
Util. byteBufferToMessage(byte[] buffer, int offset, int length)
Methods in org.jgroups.util that return types with arguments of type Message Modifier and Type Method Description static java.util.List<Message>
Util. byteBufferToMessageList(byte[] buffer, int offset, int length)
Methods in org.jgroups.util with parameters of type Message 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 itstatic java.lang.String
Util. printMethodCall(Message msg)
Tries to read aMethodCall
object from the message's buffer and prints it.Method parameters in org.jgroups.util with type arguments of type Message Modifier and Type Method Description static Buffer
Util. msgListToByteBuffer(java.util.List<Message> xmit_list)
Marshalls a list of messages.
-