Rice Pastry API

Uses of Class
rice.p2p.scribe.Topic

Packages that use Topic
rice.p2p.multiring   
rice.p2p.scribe   
rice.p2p.scribe.messaging   
rice.p2p.scribe.testing   
rice.p2p.splitstream   
rice.pastry.testing   
rice.tutorial.lesson6   
 

Uses of Topic in rice.p2p.multiring
 

Methods in rice.p2p.multiring with parameters of type Topic
 boolean MultiringNode.anycast(Topic topic, ScribeContent content)
          This method is invoked when an anycast is received for a topic which this client is interested in.
 void MultiringNode.childAdded(Topic topic, NodeHandle child)
          Informs this client that a child was added to a topic in which it was interested in.
 void MultiringNode.childRemoved(Topic topic, NodeHandle child)
          Informs this client that a child was removed from a topic in which it was interested in.
 void MultiringNode.deliver(Topic topic, ScribeContent content)
          This method is invoked when a message is delivered for a topic this client is interested in.
 void MultiringNode.subscribeFailed(Topic topic)
          Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.
 

Uses of Topic in rice.p2p.scribe
 

Fields in rice.p2p.scribe declared as Topic
protected  Topic ScribeImpl.TopicManager.topic
          DESCRIBE THE FIELD
 

Methods in rice.p2p.scribe that return Topic
 Topic ScribeImpl.TopicManager.getTopic()
          Gets the topic of the TopicManager object
 Topic[] Scribe.getTopics(ScribeClient client)
          Returns the list of topics the given client is subscribed to.
 Topic[] ScribeImpl.getTopics(ScribeClient client)
          Returns the list of topics the given client is subscribed to.
 

Methods in rice.p2p.scribe with parameters of type Topic
 void Scribe.addChild(Topic topic, NodeHandle child)
          Adds a child to the given topic
 void ScribeImpl.addChild(Topic topic, NodeHandle child)
          Adds a child to the given topic
protected  void ScribeImpl.addChild(Topic topic, NodeHandle child, int id)
          Adds a child to the given topic, using the specified sequence number in the ack message sent to the child.
 void Scribe.anycast(Topic topic, RawScribeContent content)
           
 void ScribeImpl.anycast(Topic topic, RawScribeContent content)
           
 void Scribe.anycast(Topic topic, ScribeContent content)
          Anycasts the given content to a member of the given topic
 boolean ScribeClient.anycast(Topic topic, ScribeContent content)
          This method is invoked when an anycast is received for a topic which this client is interested in.
 void ScribeImpl.anycast(Topic topic, ScribeContent content)
          Anycasts the given content to a member of the given topic
 void ScribeClient.childAdded(Topic topic, NodeHandle child)
          Informs this client that a child was added to a topic in which it was interested in.
 void ScribePolicy.childAdded(Topic topic, NodeHandle child)
          Informs this policy that a child was added to a topic - the topic is free to ignore this upcall if it doesn't care.
 void ScribePolicy.DefaultScribePolicy.childAdded(Topic topic, NodeHandle child)
          Informs this policy that a child was added to a topic - the topic is free to ignore this upcall if it doesn't care.
 void ScribeClient.childRemoved(Topic topic, NodeHandle child)
          Informs this client that a child was removed from a topic in which it was interested in.
 void ScribePolicy.childRemoved(Topic topic, NodeHandle child)
          Informs this policy that a child was removed from a topic - the topic is free to ignore this upcall if it doesn't care.
 void ScribePolicy.DefaultScribePolicy.childRemoved(Topic topic, NodeHandle child)
          Informs this policy that a child was removed from a topic - the topic is free to ignore this upcall if it doesn't care.
 void ScribeClient.deliver(Topic topic, ScribeContent content)
          This method is invoked when a message is delivered for a topic this client is interested in.
 NodeHandle[] Scribe.getChildren(Topic topic)
          Returns the list of children for a given topic
 NodeHandle[] ScribeImpl.getChildren(Topic topic)
          Returns the list of children for a given topic
 ScribeClient[] ScribeImpl.getClients(Topic topic)
          Returns the list of clients for a given topic
 NodeHandle Scribe.getParent(Topic myTopic)
          Returns the parent node for a given topic
 NodeHandle ScribeImpl.getParent(Topic topic)
          Returns the parent for a given topic
 boolean Scribe.isRoot(Topic topic)
          Returns whether or not this Scribe is the root for the given topic
 boolean ScribeImpl.isRoot(Topic topic)
          Returns whether or not this Scribe is the root for the given topic
 void Scribe.publish(Topic topic, RawScribeContent content)
           
 void ScribeImpl.publish(Topic topic, RawScribeContent content)
           
 void Scribe.publish(Topic topic, ScribeContent content)
          Publishes the given message to the topic.
 void ScribeImpl.publish(Topic topic, ScribeContent content)
          Publishes the given message to the topic.
 void Scribe.removeChild(Topic topic, NodeHandle child)
          Removes a child from the given topic
 void ScribeImpl.removeChild(Topic topic, NodeHandle child)
          Removes a child from the given topic
protected  void ScribeImpl.removeChild(Topic topic, NodeHandle child, boolean sendDrop)
          Removes a child from the given topic
 void Scribe.subscribe(Topic topic, ScribeClient client)
          Subscribes the given client to the provided topic.
 void ScribeImpl.subscribe(Topic topic, ScribeClient client)
          Subscribes the given client to the provided topic.
 void Scribe.subscribe(Topic topic, ScribeClient client, RawScribeContent content)
           
 void ScribeImpl.subscribe(Topic topic, ScribeClient client, RawScribeContent content)
           
 void Scribe.subscribe(Topic topic, ScribeClient client, ScribeContent content)
          Subscribes the given client to the provided topic.
 void ScribeImpl.subscribe(Topic topic, ScribeClient client, ScribeContent content)
          Subscribes the given client to the provided topic.
 void ScribeClient.subscribeFailed(Topic topic)
          Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.
 void Scribe.unsubscribe(Topic topic, ScribeClient client)
          Unsubscribes the given client from the provided topic.
 void ScribeImpl.unsubscribe(Topic topic, ScribeClient client)
          Unsubscribes the given client from the provided topic.
 

Constructors in rice.p2p.scribe with parameters of type Topic
ScribeImpl.TopicManager(Topic topic)
          Constructor for TopicManager.
ScribeImpl.TopicManager(Topic topic, NodeHandle child)
          Constructor for TopicManager.
ScribeImpl.TopicManager(Topic topic, ScribeClient client)
          Constructor for TopicManager.
 

Uses of Topic in rice.p2p.scribe.messaging
 

Fields in rice.p2p.scribe.messaging declared as Topic
protected  Topic ScribeMessage.topic
           
 

Methods in rice.p2p.scribe.messaging that return Topic
 Topic ScribeMessage.getTopic()
          Method which returns this messages' topic
 

Constructors in rice.p2p.scribe.messaging with parameters of type Topic
AbstractSubscribeMessage(NodeHandle source, Topic topic, int id)
          Constructor which takes a unique integer Id
AnycastMessage(NodeHandle source, Topic topic, RawScribeContent content)
           
AnycastMessage(NodeHandle source, Topic topic, ScribeContent content)
          Constructor which takes a unique integer Id
DropMessage(NodeHandle source, Topic topic)
          Constructor which takes a unique integer Id
PublishMessage(NodeHandle source, Topic topic, RawScribeContent content)
           
PublishMessage(NodeHandle source, Topic topic, ScribeContent content)
          Constructor which takes a unique integer Id
PublishRequestMessage(NodeHandle source, Topic topic, RawScribeContent content)
           
PublishRequestMessage(NodeHandle source, Topic topic, ScribeContent content)
          Constructor which takes a unique integer Id
ScribeMessage(NodeHandle source, Topic topic)
          Constructor which takes a unique integer Id
SubscribeAckMessage(NodeHandle source, Topic topic, Id[] pathToRoot, int id)
          Constructor which takes a unique integer Id
SubscribeFailedMessage(NodeHandle source, Topic topic, int id)
          Constructor which takes a unique integer Id
SubscribeLostMessage(NodeHandle source, Topic topic, int id)
          Constructor which takes a unique integer Id
SubscribeMessage(NodeHandle source, Topic topic, Id previousParent, int id, RawScribeContent content)
          Constructor which takes a unique integer Id
SubscribeMessage(NodeHandle source, Topic topic, int id, RawScribeContent content)
          Constructor which takes a unique integer Id
UnsubscribeMessage(NodeHandle source, Topic topic)
          Constructor which takes a unique integer Id
 

Uses of Topic in rice.p2p.scribe.testing
 

Fields in rice.p2p.scribe.testing declared as Topic
protected  Topic RawScribeRegrTest.TestScribeContent.topic
          DESCRIBE THE FIELD
protected  Topic RawScribeRegrTest.TestScribeClient.topic
          The topic this client is listening for
protected  Topic ScribeRegrTest.TestScribeContent.topic
          DESCRIBE THE FIELD
protected  Topic ScribeRegrTest.TestScribeClient.topic
          The topic this client is listening for
 

Methods in rice.p2p.scribe.testing with parameters of type Topic
 boolean RawScribeRegrTest.TestScribeClient.anycast(Topic topic, ScribeContent content)
          DESCRIBE THE METHOD
 boolean ScribeRegrTest.TestScribeClient.anycast(Topic topic, ScribeContent content)
          DESCRIBE THE METHOD
 void RawScribeRegrTest.TestScribeClient.childAdded(Topic topic, NodeHandle child)
          DESCRIBE THE METHOD
 void ScribeRegrTest.TestScribeClient.childAdded(Topic topic, NodeHandle child)
          DESCRIBE THE METHOD
 void RawScribeRegrTest.TestScribeClient.childRemoved(Topic topic, NodeHandle child)
          DESCRIBE THE METHOD
 void ScribeRegrTest.TestScribeClient.childRemoved(Topic topic, NodeHandle child)
          DESCRIBE THE METHOD
 void RawScribeRegrTest.TestScribeClient.deliver(Topic topic, ScribeContent content)
          DESCRIBE THE METHOD
 void ScribeRegrTest.TestScribeClient.deliver(Topic topic, ScribeContent content)
          DESCRIBE THE METHOD
 void RawScribeRegrTest.TestScribeClient.subscribeFailed(Topic topic)
           
 void ScribeRegrTest.TestScribeClient.subscribeFailed(Topic topic)
           
 

Constructors in rice.p2p.scribe.testing with parameters of type Topic
RawScribeRegrTest.TestScribeClient(Scribe scribe, Topic topic, int i)
          Constructor for TestScribeClient.
RawScribeRegrTest.TestScribeContent(Topic topic, int num)
          Constructor for TestScribeContent.
ScribeRegrTest.TestScribeClient(ScribeImpl scribe, Topic topic, int i)
          Constructor for TestScribeClient.
ScribeRegrTest.TestScribeContent(Topic topic, int num)
          Constructor for TestScribeContent.
 

Uses of Topic in rice.p2p.splitstream
 

Fields in rice.p2p.splitstream declared as Topic
protected  Topic Stripe.topic
          The topic corresponding to this stripeId
 

Methods in rice.p2p.splitstream with parameters of type Topic
 boolean Stripe.anycast(Topic topic, ScribeContent content)
          This method is invoked when an anycast is received for a topic which this client is interested in.
 void SplitStreamScribePolicy.childAdded(Topic topic, NodeHandle child)
          Informs this policy that a child was added to a topic - the topic is free to ignore this upcall if it doesn't care.
 void Stripe.childAdded(Topic topic, NodeHandle child)
          Informs this client that a child was added to a topic in which it was interested in.
 void SplitStreamScribePolicy.childRemoved(Topic topic, NodeHandle child)
          Informs this policy that a child was removed from a topic - the topic is free to ignore this upcall if it doesn't care.
 void Stripe.childRemoved(Topic topic, NodeHandle child)
          Informs this client that a child was removed from a topic in which it was interested in.
 void Stripe.deliver(Topic topic, ScribeContent content)
          This method is invoked when a message is delivered for a topic this client is interested in.
 void Stripe.subscribeFailed(Topic topic)
          Informs this client that a subscription failed
 

Uses of Topic in rice.pastry.testing
 

Fields in rice.pastry.testing declared as Topic
protected  Topic RoutingTableTest.TestScribeContent.topic
          DESCRIBE THE FIELD
 

Constructors in rice.pastry.testing with parameters of type Topic
RoutingTableTest.TestScribeContent(Topic topic, int num)
          Constructor for TestScribeContent.
 

Uses of Topic in rice.tutorial.lesson6
 

Methods in rice.tutorial.lesson6 with parameters of type Topic
 boolean MyScribeClient.anycast(Topic topic, ScribeContent content)
          Called when we receive an anycast.
 void MyScribeClient.childAdded(Topic topic, NodeHandle child)
           
 void MyScribeClient.childRemoved(Topic topic, NodeHandle child)
           
 void MyScribeClient.deliver(Topic topic, ScribeContent content)
          Called whenever we receive a published message.
 void MyScribeClient.subscribeFailed(Topic topic)
           
 


Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection