Rice Pastry API

rice.scribe.messaging
Class MessageAckOnSubscribe

java.lang.Object
  |
  +--rice.pastry.messaging.Message
        |
        +--rice.scribe.messaging.ScribeMessage
              |
              +--rice.scribe.messaging.MessageAckOnSubscribe
All Implemented Interfaces:
java.io.Serializable

public class MessageAckOnSubscribe
extends ScribeMessage
implements java.io.Serializable

Version:
$Id: MessageAckOnSubscribe.java,v 1.9 2003/06/12 21:56:13 atuls Exp $
Author:
Animesh Nandi, Atul Singh
See Also:
Serialized Form

Field Summary
 
Fields inherited from class rice.scribe.messaging.ScribeMessage
m_source, m_topicId
 
Constructor Summary
MessageAckOnSubscribe(rice.pastry.messaging.Address addr, rice.pastry.NodeHandle source, rice.pastry.NodeId tid, rice.pastry.security.Credentials c, java.io.Serializable data)
          Constructor
 
Method Summary
 void handleDeliverMessage(rice.scribe.Scribe scribe, rice.scribe.Topic topic)
          This method is called whenever the scribe node receives a message for itself and wants to process it.
 boolean handleForwardMessage(rice.scribe.Scribe scribe, rice.scribe.Topic topic)
          This method is called whenever the scribe node forwards a message in the scribe network.
 java.lang.String toString()
           
 
Methods inherited from class rice.scribe.messaging.ScribeMessage
getData, getSource, getTopicId, setData
 
Methods inherited from class rice.pastry.messaging.Message
getCredentials, getDate, getDestination, getSenderId, getStream, hasPriority, setPriority, setSenderId, stamp
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MessageAckOnSubscribe

public MessageAckOnSubscribe(rice.pastry.messaging.Address addr,
                             rice.pastry.NodeHandle source,
                             rice.pastry.NodeId tid,
                             rice.pastry.security.Credentials c,
                             java.io.Serializable data)
Constructor

Parameters:
addr - the address of the scribe receiver.
source - the node generating the message.
tid - the topic to which this message refers to.
c - the credentials associated with the mesasge.
data - the data to be sent along the message
Method Detail

handleDeliverMessage

public void handleDeliverMessage(rice.scribe.Scribe scribe,
                                 rice.scribe.Topic topic)
This method is called whenever the scribe node receives a message for itself and wants to process it. The processing is delegated by scribe to the message.

Specified by:
handleDeliverMessage in class ScribeMessage
Parameters:
scribe - the scribe application.
topic - the topic within the scribe application.

handleForwardMessage

public boolean handleForwardMessage(rice.scribe.Scribe scribe,
                                    rice.scribe.Topic topic)
This method is called whenever the scribe node forwards a message in the scribe network. The processing is delegated by scribe to the message.

Specified by:
handleForwardMessage in class ScribeMessage
Parameters:
scribe - the scribe application.
topic - the topic within the scribe application.
Returns:
true if the message should be routed further, false otherwise.

toString

public java.lang.String toString()
Specified by:
toString in class ScribeMessage

Rice Pastry API

Copyright © 2001 - Rice Pastry.


Imprint-Dataprotection