| 
Rice Pastry API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| Packages that use Topic | |
| rice.p2p.multiring | |
| rice.p2p.scribe | |
| rice.p2p.scribe.messaging | |
| rice.p2p.scribe.testing | |
| rice.p2p.splitstream | |
| 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.deliver(Topic topic,
        ScribeContent content)
This method is invoked when a message is delivered for a topic 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.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[] | 
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.  | 
 Topic | 
ScribeImpl.TopicManager.getTopic()
Gets the topic of the TopicManager object  | 
| Methods in rice.p2p.scribe with parameters of type Topic | |
 void | 
Scribe.subscribe(Topic topic,
          ScribeClient client)
Subscribes the given client to the provided topic.  | 
 void | 
Scribe.subscribe(Topic topic,
          ScribeClient client,
          ScribeContent content)
Subscribes the given client to the provided topic.  | 
 void | 
Scribe.unsubscribe(Topic topic,
            ScribeClient client)
Unsubscribes the given client from the provided topic.  | 
 void | 
Scribe.publish(Topic topic,
        ScribeContent content)
Publishes the given message to the topic.  | 
 void | 
Scribe.anycast(Topic topic,
        ScribeContent content)
Anycasts the given content to a member of the given topic  | 
 boolean | 
Scribe.isRoot(Topic topic)
Returns whether or not this Scribe is the root for the given topic  | 
 NodeHandle[] | 
Scribe.getChildren(Topic topic)
Returns the list of children for a given topic  | 
 NodeHandle | 
Scribe.getParent(Topic myTopic)
Returns the parent node for a given topic  | 
 void | 
Scribe.addChild(Topic topic,
         NodeHandle child)
Adds a child to the given topic  | 
 void | 
Scribe.removeChild(Topic topic,
            NodeHandle child)
Removes a child from 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 | 
ScribeClient.deliver(Topic topic,
        ScribeContent content)
This method is invoked when a message is delivered for a topic this client is interested in.  | 
 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 | 
ScribeClient.childRemoved(Topic topic,
             NodeHandle child)
Informs this client that a child was removed from a topic in which it was interested in.  | 
 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.  | 
 ScribeClient[] | 
ScribeImpl.getClients(Topic topic)
Returns the list of clients for a given topic  | 
 NodeHandle[] | 
ScribeImpl.getChildren(Topic topic)
Returns the list of children for a given topic  | 
 NodeHandle | 
ScribeImpl.getParent(Topic topic)
Returns the parent for a given topic  | 
 boolean | 
ScribeImpl.isRoot(Topic topic)
Returns whether or not this Scribe is the root for the given topic  | 
 void | 
ScribeImpl.subscribe(Topic topic,
          ScribeClient client)
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 | 
ScribeImpl.unsubscribe(Topic topic,
            ScribeClient client)
Unsubscribes the given client from the provided topic.  | 
 void | 
ScribeImpl.publish(Topic topic,
        ScribeContent content)
Publishes the given message to the topic.  | 
 void | 
ScribeImpl.anycast(Topic topic,
        ScribeContent content)
Anycasts the given content to a member of 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 | 
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 | 
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.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.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.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.  | 
| Constructors in rice.p2p.scribe with parameters of type Topic | |
ScribeImpl.TopicManager(Topic topic,
                        ScribeClient client)
Constructor for TopicManager.  | 
|
ScribeImpl.TopicManager(Topic topic,
                        NodeHandle child)
Constructor for TopicManager.  | 
|
ScribeImpl.TopicManager(Topic topic)
Constructor for TopicManager.  | 
|
| Uses of Topic in rice.p2p.scribe.messaging | 
| Fields in rice.p2p.scribe.messaging declared as Topic | |
protected  Topic | 
ScribeMessage.topic
DESCRIBE THE FIELD  | 
| 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,
               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,
               ScribeContent content)
Constructor which takes a unique integer Id  | 
|
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,
                 int id,
                 ScribeContent content)
Constructor which takes a unique integer Id  | 
|
SubscribeMessage(NodeHandle source,
                 Topic topic,
                 Id previousParent,
                 int id,
                 ScribeContent 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 | 
ScribeRegrTest.TestScribeClient.topic
The topic this client is listening for  | 
protected  Topic | 
ScribeRegrTest.TestScribeContent.topic
DESCRIBE THE FIELD  | 
| Methods in rice.p2p.scribe.testing with parameters of type Topic | |
 boolean | 
ScribeRegrTest.TestScribeClient.anycast(Topic topic,
        ScribeContent content)
DESCRIBE THE METHOD  | 
 void | 
ScribeRegrTest.TestScribeClient.deliver(Topic topic,
        ScribeContent content)
DESCRIBE THE METHOD  | 
 void | 
ScribeRegrTest.TestScribeClient.childAdded(Topic topic,
           NodeHandle child)
DESCRIBE THE METHOD  | 
 void | 
ScribeRegrTest.TestScribeClient.childRemoved(Topic topic,
             NodeHandle child)
DESCRIBE THE METHOD  | 
 void | 
ScribeRegrTest.TestScribeClient.subscribeFailed(Topic topic)
DESCRIBE THE METHOD  | 
| Constructors in rice.p2p.scribe.testing with parameters of type Topic | |
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 | |
 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 | 
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.  | 
 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 | 
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.childAdded(Topic topic,
           NodeHandle child)
Informs this client that a child was added to a topic in which it was interested in.  | 
 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.subscribeFailed(Topic topic)
Informs this client that a subscription failed  | 
| Uses of Topic in rice.tutorial.lesson6 | 
| Methods in rice.tutorial.lesson6 with parameters of type Topic | |
 void | 
MyScribeClient.deliver(Topic topic,
        ScribeContent content)
Called whenever we receive a published message.  | 
 boolean | 
MyScribeClient.anycast(Topic topic,
        ScribeContent content)
Called when we receive an anycast.  | 
 void | 
MyScribeClient.childAdded(Topic topic,
           NodeHandle child)
DESCRIBE THE METHOD  | 
 void | 
MyScribeClient.childRemoved(Topic topic,
             NodeHandle child)
DESCRIBE THE METHOD  | 
 void | 
MyScribeClient.subscribeFailed(Topic topic)
DESCRIBE THE METHOD  | 
  | 
Rice Pastry API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||