Uses of Class org.jgroups.Message

Uses in package org.jgroups.demos.wb

Methods with parameter type org.jgroups.Message

void

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Message

void
void

Uses in package org.jgroups.stack

Methods with parameter type org.jgroups.Message

void
AckReceiverWindow.add(long seqno, Message msg)
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
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
Receives a message from the router (blocking mode).
Message
Removes a message whose seqno is equal to next_to_remove, increments the latter.
Message
Returns the first entry (with the lowest seqno) from the received_msgs map if its associated message is not null, otherwise returns null.

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
ConnectionTable.Receiver interface
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.

Uses in package org.jgroups

Methods with parameter type org.jgroups.Message

void
void
Sends a message to a (unicast) destination.
void
void
implementation of the Transport interface.
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
Calls the receiver callback.
void
void
void
void
void
Receive message from group.
void
void
void
Callback.
void
void
Receive the message.
boolean
Handles a message coming from a layer below
void
Callback (called by RequestCorrelator or Transport).
void
void
GroupRequest.reset(Message m, Vector members, int rsp_mode, long timeout, int expected_rsps)
void
GroupRequest.reset(Message m, int mode, long timeout)
Resets the group request, so it can be reused for another execution.
void
PullPushAdapter.send(Serializable identifier, Message msg)
Sends a message to the group - listeners to this identifier will receive the messages
void
Sends a message to a unicast destination.
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.

Copyright B) 2001,2002 www.jgroups.com . All Rights Reserved.