Uses of Class org.jgroups.Message

Uses in package org.jgroups.demos.wb

Methods with parameter type org.jgroups.Message

void
Called when a message is received.

Uses in package org.jgroups.protocols

Methods with parameter type org.jgroups.Message

Object
Called when a request for this protocol layer is received.
Object
Callback.
Object
void
void
TCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
TCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void
TP.postUnmarshallingList(Message msg, Address dest, 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
SMACK.retransmit(long seqno, Message msg, Address dest)
Retranmit the given msg
void
Publish message in the JMS topic.
void
Sets a message associated with this vector timestamp

Methods with return type org.jgroups.Message

Message
Returns a message associated with this vector timestamp.

Uses in package org.jgroups

Methods with parameter type org.jgroups.Message

void
Called when a message is received.
void
Called when a message is received.
void
Sends a message to a (unicast) destination.
void
Sends a message through the protocol stack.
void

Methods with return type org.jgroups.Message

Message
Message
Message.copy(boolean copy_buffer)
Create a copy of the message.
Message

Uses in package org.jgroups.blocks

Constructors with parameter type org.jgroups.Message

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

Fields of type org.jgroups.Message

Message

Methods with parameter type org.jgroups.Message

void
MessageDispatcher.castMessage(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(Vector dests, Message msg, int mode, long timeout)
Cast a message to all members, and wait for mode responses.
RspList
RpcDispatcher.castMessage(Vector dests, Message msg, int mode, long timeout)
Object
Object
Object
Object
Message contains MethodCall.
void
Check whether the message has an identifier.
void
Called when a message is received.
void
Called when a message is received.
void
Called when a message is received.
void
Receive message from group.
void
Called when a message is received.
void
Called when a message is received.
void
Callback.
void
Receive the message.
boolean
Handles a message coming from a layer below
void
Callback (called by RequestCorrelator or Transport).
void
void
PullPushAdapter.send(Serializable identifier, Message msg)
Sends a message to the group - listeners to this identifier will receive the messages.
void
void
Sends a message with no identifier; listener member will get this message on the other group members.
Object
MessageDispatcher.sendMessage(Message msg, int mode, long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response.
Object
RpcDispatcher.sendMessage(Message msg, int mode, long timeout)
void
RequestCorrelator.sendRequest(long id, List dest_mbrs, Message msg, RspCollector coll)
Send a request to a group.
void

Uses in package org.jgroups.util

Methods with parameter type org.jgroups.Message

String
Tries to read an object from the message's buffer and prints it
String
Tries to read a MethodCall object from the message's buffer and prints it.

Uses in package org.jgroups.protocols.pbcast

Methods with parameter type org.jgroups.Message

void

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Message

void
void
Called when a message is received.

Uses in package org.jgroups.stack

Methods with parameter type org.jgroups.Message

void
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.
void
NakReceiverWindow.add(long seqno, Message msg)
Adds a message according to its sequence number (ordered).
void
AckMcastSenderWindow.add(long seqno, Message msg, Vector receivers)
Adds a new message to the hash table.
RspList
MessageProtocol.castMessage(Vector dests, Message msg, int mode, long timeout)
Cast a message to all members, and wait for mode responses.
Object
Processes a request destined for this layer.
Object
Message contains MethodCall.
void
void
void
Retranmit the given msg
void
boolean
RouterStub.send(Message msg, String groupname)
Sends a message to the router.
Object
MessageProtocol.sendMessage(Message msg, int mode, long timeout)
Sends a message to a single member (destination = msg.dest) and returns the response.

Methods with return type org.jgroups.Message

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

Uses in package org.jgroups.jmx

Methods with parameter type org.jgroups.Message

void
void

Copyright B) 1998-2005 Bela Ban. All Rights Reserved.