Rice Pastry API

Uses of Class
rice.scribe.messaging.ScribeMessage

Packages that use ScribeMessage
rice.pastry.multiring   
rice.scribe   
rice.scribe.maintenance   
rice.scribe.messaging   
rice.scribe.testing   
 

Uses of ScribeMessage in rice.pastry.multiring
 

Methods in rice.pastry.multiring with parameters of type ScribeMessage
 boolean MultiRingAppl.anycastHandler(rice.scribe.messaging.ScribeMessage msg)
           
 void MultiRingAppl.receiveMessage(rice.scribe.messaging.ScribeMessage msg)
           
 void MultiRingAppl.forwardHandler(rice.scribe.messaging.ScribeMessage msg)
           
 void MultiRingAppl.faultHandler(rice.scribe.messaging.ScribeMessage msg, rice.pastry.NodeHandle faultyParent)
           
 

Uses of ScribeMessage in rice.scribe
 

Methods in rice.scribe that return ScribeMessage
 rice.scribe.messaging.ScribeMessage Scribe.makeSubscribeMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes a subscribe message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeUnsubscribeMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes an unsubscribe message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeCreateMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes a create message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makePublishMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes a publish message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeAnycastMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes a anycast message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeHeartBeatMessage(rice.pastry.security.Credentials c)
          Makes a heart-beat message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeAckOnSubscribeMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c)
          Makes a AckOnSubscribe message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeAckOnSubscribeMessage(rice.pastry.NodeId tid, rice.pastry.security.Credentials c, java.io.Serializable data)
          Makes a AckOnSubscribe message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeRequestToParentMessage(rice.pastry.security.Credentials c)
          Makes a RequestToParent message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeReplyFromParentMessage(rice.pastry.security.Credentials c)
          Makes a ReplyFromParent message using the current Pastry node as the source.
 rice.scribe.messaging.ScribeMessage Scribe.makeScribeMaintenanceMessage(rice.pastry.security.Credentials c)
          Makes a ScribeMaintenance message using the current Pastry node as the source.
 

Methods in rice.scribe with parameters of type ScribeMessage
 void IScribeApp.receiveMessage(rice.scribe.messaging.ScribeMessage msg)
          Called by Scribe when a multicast message arrives.
 void IScribeApp.forwardHandler(rice.scribe.messaging.ScribeMessage msg)
          Called by Scribe before the node forwards a message to its children in the multicast tree.
 void IScribeApp.faultHandler(rice.scribe.messaging.ScribeMessage msg, rice.pastry.NodeHandle faultyParent)
          Invoked by Scribe just before the "repair" SUBSCRIBE message is sent when a node suspects its parent is faulty.
 boolean IScribeApp.anycastHandler(rice.scribe.messaging.ScribeMessage msg)
          Invoked by underlying scribe when it receives a anycast Message, to check if there is a local application which can take care of this anycast message.
 void Scribe.childObserver(rice.pastry.NodeHandle child, rice.pastry.NodeId topicId, boolean wasAdded, rice.scribe.messaging.ScribeMessage pmsg, java.io.Serializable data)
          Whenever the children table for a topic is changed, ( a child is added or removed), this method is invoked to do some handling.
 boolean Topic.addChild(rice.pastry.NodeHandle child, rice.scribe.messaging.ScribeMessage msg)
          Adds a node to the Set of children in this topic's multicast subtree rooted at this node
 boolean Topic.addChild(rice.pastry.NodeHandle child, rice.scribe.messaging.ScribeMessage msg, java.io.Serializable data)
          Adds a node to the Set of children in this topic's multicast subtree rooted at this node.
 boolean Topic.removeChild(rice.pastry.NodeHandle child, rice.scribe.messaging.ScribeMessage msg)
          Removes a node from the Set of children in this topic's multicast subtree rooted at this node
 

Uses of ScribeMessage in rice.scribe.maintenance
 

Subclasses of ScribeMessage in rice.scribe.maintenance
 class MessageScribeMaintenance
          MessageScribeMaintenance is used by a Scribe node to initiate tree maintenance activities for the topics residing on the local node.
 

Uses of ScribeMessage in rice.scribe.messaging
 

Subclasses of ScribeMessage in rice.scribe.messaging
 class MessageAckOnSubscribe
           
 class MessageAnycast
          MessageAnycast is used whenever a Scribe node wishes to anycast to a particular topic.
 class MessageCreate
          MessageCreate is used whenever a Scribe node wants to create a new topic.
 class MessageHeartBeat
          HeartBeatMessage is used whenever a Scribe nodes wishes let its children know that it is still alive, so that the children need not do any repairing of the multicast tree.
 class MessagePublish
          MessagePublish is used whenever a Scribe nodes wishes to send events to a particular topic.
 class MessageReplyFromParent
          MessageReplyFromParent is a message sent by the PARENT node to a node as a response to a MessageRequestToParent type of message.
 class MessageRequestToParent
          MessageRequestToParent is a message sent by a CHILD node to the PARENT requesting it for the list of topics for which the PARENT node has this node as a CHILD.
 class MessageSubscribe
          MessageSubscribe is used whenever a Scribe node wants to subscribe itself to a topic.
 class MessageUnsubscribe
          MessageUnsubscribe is used whenever a Scribe node wishes to unsubscribe from a topic.
 

Uses of ScribeMessage in rice.scribe.testing
 

Subclasses of ScribeMessage in rice.scribe.testing
 class DirectScribeMaintenanceTest.TestAnycastMessage
          A dummy test message used for checking if anycast is doing DFS correctly.
 

Methods in rice.scribe.testing with parameters of type ScribeMessage
 void BasicScribeRegrTestApp.receiveMessage(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is 'delivered'.
 void BasicScribeRegrTestApp.forwardHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is forwarded through the multicast tree.
 boolean BasicScribeRegrTestApp.anycastHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by Scribe when an anycast message is being handled.
 void BasicScribeRegrTestApp.faultHandler(rice.scribe.messaging.ScribeMessage msg, rice.pastry.NodeHandle parent)
          up-call invoked by scribe when a node detects a failure from its parent.
 void DirectScribeMaintenanceTestApp.receiveMessage(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is 'delivered'.
 void DirectScribeMaintenanceTestApp.forwardHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is forwarded through the multicast tree.
 void DirectScribeMaintenanceTestApp.faultHandler(rice.scribe.messaging.ScribeMessage msg, rice.pastry.NodeHandle parent)
          up-call invoked by scribe when a node detects a failure from its parent.
 boolean DirectScribeMaintenanceTestApp.anycastHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by Scribe when an anycast message is being handled.
 void DistScribeRegrTestApp.receiveMessage(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is 'delivered'.
 void DistScribeRegrTestApp.forwardHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by scribe when a publish message is forwarded through the multicast tree.
 void DistScribeRegrTestApp.faultHandler(rice.scribe.messaging.ScribeMessage msg, rice.pastry.NodeHandle parent)
          up-call invoked by scribe when a node detects a failure from its parent.
 boolean DistScribeRegrTestApp.anycastHandler(rice.scribe.messaging.ScribeMessage msg)
          up-call invoked by Scribe when an anycast message is being handled.
 


Rice Pastry API

Copyright © 2001 - Rice Pastry.


Imprint-Dataprotection