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)
Called when a message is received.

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.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
JMS.sendMessage(Message msg)
Publish message in the JMS topic.
void
TransportedVectorTime.setAssociatedMessage(Message owner)
Sets a message associated with this vector timestamp

Methods with return type org.jgroups.Message

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

Uses in package org.jgroups

Methods with parameter type org.jgroups.Message

void
MessageListener.receive(Message msg)
Called when a message is received.
void
ReceiverAdapter.receive(Message msg)
Called when a message is received.
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)

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
DistributedHashtable.receive(Message msg)
Called when a message is received.
void
DistributedQueue.receive(Message msg)
Called when a message is received.
void
DistributedTree.receive(Message msg)
Called when a message is received.
void
MessageListenerAdapter.receive(Message msg)
Receive message from group.
void
NotificationBus.receive(Message msg)
Called when a message is received.
void
ReplicatedHashtable.receive(Message msg)
Called when a message is received.
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 below
void
GroupRequest.receiveResponse(Message m)
Callback (called by RequestCorrelator or Transport).
void
RspCollector.receiveResponse(Message msg)
void
PullPushAdapter.send(Serializable identifier, Message msg)
Sends a message to the group - listeners to this identifier will receive the messages.
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.

Uses in package org.jgroups.protocols.pbcast

Methods with parameter type org.jgroups.Message

void
NAKACK.missingMessageReceived(long seqno, Message msg)

Uses in package org.jgroups.demos

Methods with parameter type org.jgroups.Message

void
Chat.receive(Message msg)
void
QuoteServer.receive(Message msg)
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
MessageProtocol.handle(Message req)
Processes a request destined for this layer.
Object
RpcProtocol.handle(Message req)
Message contains MethodCall.
void
NakReceiverWindow.Listener.missingMessageReceived(long seqno, Message msg)
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
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.
Message
NakReceiverWindow.remove()

Uses in package org.jgroups.jmx

Methods with parameter type org.jgroups.Message

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

Overview Package Class Use Tree Index Deprecated About
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.