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
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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
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
Copyright © 2001 - Rice Pastry.