Uses of Class
org.javagroups.Message

Packages that use Message
org.javagroups   
org.javagroups.blocks   
org.javagroups.demos   
org.javagroups.demos.wb   
org.javagroups.protocols   
org.javagroups.stack   
org.javagroups.util   
 

Uses of Message in org.javagroups
 

Methods in org.javagroups that return Message
 Message Message.copy()
           
 Message Message.makeReply()
           
 

Methods in org.javagroups with parameters of type Message
 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)
           
abstract  void Channel.send(Message msg)
          Sends a message to a (unicast) destination.
 void MessageListener.receive(Message msg)
           
 

Uses of Message in org.javagroups.blocks
 

Fields in org.javagroups.blocks declared as Message
protected  Message GroupRequest.request_msg
           
 

Methods in org.javagroups.blocks with parameters of type Message
 void ConnectionTable1_4.send(Message msg)
          Sends a message to a unicast destination.
 void ConnectionTable1_4.receive(Message msg)
          Calls the receiver callback.
 void ConnectionTable1_4.Receiver.receive(Message msg)
           
 void TransactionalHashtable.receive(Message msg)
           
 java.lang.Object ReplicationManager.handle(Message msg)
           
 void ReplicatedTree.receive(Message msg)
          Callback.
 void ReplicatedHashtable.receive(Message msg)
           
 void NotificationBus.receive(Message msg)
           
 void MessageListenerAdapter.receive(Message msg)
          Receive message from group.
 void GroupRequest.reset(Message m, int mode, long timeout)
          Resets the group request, so it can be reused for another execution.
 void GroupRequest.reset(Message m, java.util.Vector members, int rsp_mode, long timeout, int expected_rsps)
           
 void GroupRequest.receiveResponse(Message m)
          Callback (called by RequestCorrelator or Transport).
 void DistributedTree.receive(Message msg)
           
 void DistributedQueue.receive(Message msg)
           
 void VotingAdapter.receive(Message msg)
          Receive the message.
 void RspCollector.receiveResponse(Message msg)
           
 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 PullPushAdapter.send(java.io.Serializable identifier, Message msg)
           
 void PullPushAdapter.send(Message msg)
           
protected  void PullPushAdapter.handleMessage(Message msg)
          Check whether the message has an identifier.
 java.lang.Object RequestHandler.handle(Message msg)
           
 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)
           
 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 DistributedHashtable.receive(Message msg)
           
 void ConnectionTable.send(Message msg)
          Sends a message to a unicast destination.
 void ConnectionTable.receive(Message msg)
          Calls the receiver callback.
 void ConnectionTable.Receiver.receive(Message msg)
           
 

Constructors in org.javagroups.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.javagroups.demos
 

Methods in org.javagroups.demos with parameters of type Message
 void QuoteServer.receive(Message msg)
           
 void Chat.receive(Message msg)
           
 

Uses of Message in org.javagroups.demos.wb
 

Methods in org.javagroups.demos.wb with parameters of type Message
 void Whiteboard.receive(Message m)
           
 

Uses of Message in org.javagroups.protocols
 

Methods in org.javagroups.protocols with parameters of type Message
 void UNICAST.retransmit(long seqno, Message msg)
          Called by AckSenderWindow to resend messages for which no ACK has been received yet
 void TUNNEL.handleIncomingMessage(Message msg)
           
 void TCP.receive(Message msg)
          ConnectionTable.Receiver interface
 java.lang.Object STATE_TRANSFER.handle(Message msg)
           
 void SMACK.retransmit(long seqno, Message msg, Address dest)
           
 java.lang.Object MessageProtocolEXAMPLE.handle(Message req)
          Callback.
protected  void JMS.sendMessage(Message msg)
          Publish message in the JMS topic.
 java.lang.Object FLOW_CONTROL.handle(Message req)
          Called when a request for this protocol layer is received.
 

Uses of Message in org.javagroups.stack
 

Methods in org.javagroups.stack that return Message
 Message NakReceiverWindow.remove()
          Find the entry with seqno head.
 Message AckReceiverWindow.remove()
          Removes a message whose seqno is equal to next_to_remove, increments the latter.
 Message RouterStub.receive()
          Receives a message from the router (blocking mode).
 

Methods in org.javagroups.stack with parameters of type Message
 void NakReceiverWindow.add(long seqno, Message msg)
          Adds a message according to its sequence number (ordered).
 void AckReceiverWindow.add(long seqno, Message msg)
           
 void AckSenderWindow.add(long seqno, Message msg)
          Adds a new message to the retransmission table.
 void AckSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg)
           
 void AckMcastSenderWindow.add(long seqno, Message msg, java.util.Vector receivers)
          Adds a new message to the hash table.
 void AckMcastSenderWindow.RetransmitCommand.retransmit(long seqno, Message msg, Address dest)
          Retranmit the given msg
 boolean RouterStub.send(Message msg, java.lang.String groupname)
          Sends a message to the router.
 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.
 java.lang.Object RpcProtocol.handle(Message req)
          Message contains MethodCall.
 void ProtocolStack.send(Message msg)
           
 

Uses of Message in org.javagroups.util
 

Methods in org.javagroups.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.
 



Copyright © 2001,2002 www.javagroups.com . All Rights Reserved.