Overview Package Class Use Tree Index Deprecated About
Frames | No Frames

Uses of Class org.jgroups.Message

Uses in package org.jgroups.demos.wb

Methods with parameter type org.jgroups.Message

void
Whiteboard.receive(Message m)

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Message

void
Chat.receive(Message msg)
void
QuoteServer.receive(Message msg)

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
MessageProtocol.handle(Message req)
Processes a request destined for this layer.
Object
RpcProtocol.handle(Message req)
Message contains MethodCall.
void
AckSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg)
void
AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)
Retranmit the given msg
void
ProtocolStack.send(Message msg)
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
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.
Message
NakReceiverWindow.remove()
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
FLOW_CONTROL.handle(Message req)
Called when a request for this protocol layer is received.
Object
MessageProtocolEXAMPLE.handle(Message req)
Callback.
Object
STATE_TRANSFER.handle(Message msg)
void
TUNNEL.handleIncomingMessage(Message msg)
void
TCP.receive(Message msg)
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
JMS.sendMessage(Message msg)
Publish message in the JMS topic.

Uses in package org.jgroups

Methods with parameter type org.jgroups.Message

void
MessageListener.receive(Message msg)
void
Channel.send(Message msg)
Sends a message to a (unicast) destination.
void
EnsChannel.send(Message msg)
void
JChannel.send(Message msg)
implementation of the Transport interface.
Sends a message through the protocol stack
void
Transport.send(Message msg)

Methods with return type org.jgroups.Message

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

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
GroupRequest.request_msg

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
MessageDispatcher.handle(Message msg)
Object
ReplicationManager.handle(Message msg)
Object
RequestHandler.handle(Message msg)
Object
RpcDispatcher.handle(Message req)
Message contains MethodCall.
void
PullPushAdapter.handleMessage(Message msg)
Check whether the message has an identifier.
void
ConnectionTable.receive(Message msg)
Calls the receiver callback.
void
ConnectionTable.Receiver.receive(Message msg)
void
DistributedHashtable.receive(Message msg)
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
ReplicatedHashtable.receive(Message msg)
void
ReplicatedTree.receive(Message msg)
Callback.
void
TransactionalHashtable.receive(Message msg)
void
VotingAdapter.receive(Message msg)
Receive the message.
boolean
RequestCorrelator.receiveMessage(Message msg)
Handles a message coming from a layer below
void
GroupRequest.receiveResponse(Message m)
Callback (called by RequestCorrelator or Transport).
void
RspCollector.receiveResponse(Message msg)
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
ConnectionTable.send(Message msg)
Sends a message to a unicast destination.
void
MessageDispatcher.send(Message msg)
void
PullPushAdapter.send(Message msg)
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
RequestCorrelator.sendRequest(long id, Message msg, RspCollector coll)
Helper method for sendRequest(long,List,Message,RspCollector).

Uses in package org.jgroups.util

Methods with parameter type org.jgroups.Message

String
Util.printMessage(Message msg)
Tries to read an object from the message's buffer and prints it
String
Util.printMethodCall(Message msg)
Tries to read a MethodCall object from the message's buffer and prints it.

Overview Package Class Use Tree Index Deprecated About
Copyright B) 2001,2002 www.jgroups.com . All Rights Reserved.