|
Rice Pastry API | ||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | ||||||||||
PREV NEXT | FRAMES NO FRAMES |