Uses of Class
org.jgroups.Message

Packages that use Message

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.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
org.jgroups.jmx
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.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

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

abstract void	Channel.send(Message msg) Sends a message to a (unicast) destination.
void	Transport.send(Message msg)
void	MessageListener.receive(Message msg) Called when a message is received.
void	JChannel.send(Message msg) Sends a message through the protocol stack.
void	ReceiverAdapter.receive(Message msg)

Uses of Message in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Message

protected Message

GroupRequest.request_msg

Methods in org.jgroups.blocks with parameters of type Message

void	DistributedHashtable.receive(Message msg)
RspList	RpcDispatcher.castMessage(java.util.Vector dests, Message msg, int mode, long timeout)
java.lang.Object	RpcDispatcher.sendMessage(Message msg, int mode, long timeout)
java.lang.Object	RpcDispatcher.handle(Message req) Message contains MethodCall.
void	MessageDispatcher.send(Message msg)
RspList	MessageDispatcher.castMessage(java.util.Vector dests, Message msg, int mode, long timeout) Cast a message to all members, and wait for mode responses.
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.
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	MessageDispatcher.handle(Message msg)
java.lang.Object	RequestHandler.handle(Message msg)
void	PullPushAdapter.send(java.io.Serializable identifier, Message msg) Sends a message to the group - listeners to this identifier will receive the messages.
void	PullPushAdapter.send(Message msg) Sends a message with no identifier; listener member will get this message on the other group members.
protected void	PullPushAdapter.handleMessage(Message msg) Check whether the message has an identifier.
void	RequestCorrelator.sendRequest(long id, Message msg, RspCollector coll) Helper method for RequestCorrelator.sendRequest(long,List,Message,RspCollector).
void	RequestCorrelator.sendRequest(long id, java.util.List dest_mbrs, Message msg, RspCollector coll) Send a request to a group.
boolean	RequestCorrelator.receiveMessage(Message msg) Handles a message coming from a layer below
void	RspCollector.receiveResponse(Message msg)
void	VotingAdapter.receive(Message msg) Receive the message.
void	DistributedQueue.receive(Message msg)
void	DistributedTree.receive(Message msg)
void	GroupRequest.receiveResponse(Message m) Callback (called by RequestCorrelator or Transport).
void	MessageListenerAdapter.receive(Message msg) Receive message from group.
void	NotificationBus.receive(Message msg)
void	ReplicatedHashtable.receive(Message msg)
void	ReplicatedTree.receive(Message msg) Callback.
java.lang.Object	ReplicationManager.handle(Message msg)

Constructors in org.jgroups.blocks with parameters of type Message

GroupRequest(Message m, RequestCorrelator corr, java.util.Vector members, int rsp_mode)

GroupRequest(Message m, RequestCorrelator corr, java.util.Vector members, int rsp_mode, long timeout, int expected_mbrs)

GroupRequest(Message m, Transport transport, java.util.Vector members, int rsp_mode)

GroupRequest(Message m, Transport transport, java.util.Vector 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

void	Chat.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

void	Whiteboard.receive(Message m)

Uses of Message in org.jgroups.jmx

Methods in org.jgroups.jmx with parameters of type Message

void	JChannel.send(Message msg)
void	JChannelMBean.send(Message msg)

Uses of Message in org.jgroups.protocols

Methods in org.jgroups.protocols that return Message

Message

TransportedVectorTime.getAssociatedMessage() Returns a message associated with this vector timestamp.

Methods in org.jgroups.protocols with parameters of type Message

void	TCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	TCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
abstract void	TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
abstract void	TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	UNICAST.retransmit(long seqno, Message msg) Called by AckSenderWindow to resend messages for which no ACK has been received yet
void	TransportedVectorTime.setAssociatedMessage(Message owner) Sets a message associated with this vector timestamp
java.lang.Object	FLOW_CONTROL.handle(Message req) Called when a request for this protocol layer is received.
protected void	JMS.sendMessage(Message msg) Publish message in the JMS topic.
java.lang.Object	MessageProtocolEXAMPLE.handle(Message req) Callback.
void	SMACK.retransmit(long seqno, Message msg, Address dest)
java.lang.Object	STATE_TRANSFER.handle(Message msg)
void	TUNNEL.handleIncomingMessage(Message msg)

Uses of Message in org.jgroups.protocols.pbcast

Methods in org.jgroups.protocols.pbcast with parameters of type Message

void	NAKACK.missingMessageReceived(long seqno, Message msg)

Uses of Message in org.jgroups.stack

Methods in org.jgroups.stack that return Message

Message	NakReceiverWindow.remove()
Message	NakReceiverWindow.get(long sequence_num) Returns the message from received_msgs or delivered_msgs.
Message	RouterStub.receive() Receives a message from the router (blocking mode).
Message	AckReceiverWindow.remove() Removes a message whose seqno is equal to next_to_remove, increments the latter.

Methods in org.jgroups.stack with parameters of type Message

void	ProtocolStack.send(Message msg)
void	AckSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg)
void	AckSenderWindow.add(long seqno, Message msg) Adds a new message to the retransmission table.
void	NakReceiverWindow.Listener.missingMessageReceived(long seqno, Message msg)
void	NakReceiverWindow.add(long seqno, Message msg) Adds a message according to its sequence number (ordered).
java.lang.Object	RpcProtocol.handle(Message req) Message contains MethodCall.
RspList	MessageProtocol.castMessage(java.util.Vector dests, Message msg, int mode, long timeout) Cast a message to all members, and wait for mode responses.
java.lang.Object	MessageProtocol.sendMessage(Message msg, int mode, long timeout) Sends a message to a single member (destination = msg.dest) and returns the response.
java.lang.Object	MessageProtocol.handle(Message req) Processes a request destined for this layer.
boolean	RouterStub.send(Message msg, java.lang.String groupname) Sends a message to the router.
void	AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest) Retranmit the given msg
void	AckMcastSenderWindow.add(long seqno, Message msg, java.util.Vector receivers) Adds a new message to the hash table.
void	AckReceiverWindow.add(long seqno, Message msg) Adds a new message.

Uses of Message in org.jgroups.util

Methods in org.jgroups.util with parameters of type Message

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.