Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV NEXT | FRAMES NO FRAMES

## Uses of Class
rice.p2p.scribe.Topic

Packages that use Topic
org.mpisws.p2p.testing.transportlayer.replay |
rice.p2p.multiring |
rice.p2p.scribe |
rice.p2p.scribe.javaserialized |
rice.p2p.scribe.maintenance |
rice.p2p.scribe.messaging |
rice.p2p.scribe.rawserialization |
rice.p2p.scribe.testing |
rice.p2p.splitstream |
rice.pastry.testing |
rice.tutorial.scribe |

Uses of Topic in org.mpisws.p2p.testing.transportlayer.replay

Methods in org.mpisws.p2p.testing.transportlayer.replay 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)`

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

Fields in rice.p2p.scribe with type parameters of type Topic
`java.util.HashMap<NodeHandle,java.util.Collection<Topic>>` | `ScribeImpl.allChildren` This contains a mapping of child - > all topics for which the local node has this node(hashtable key) as a child
`java.util.HashMap<NodeHandle,java.util.Collection<Topic>>` | `ScribeImpl.allParents` This contains a mapping of parent - > all topics for which the local node has this node(hashtable key) as a parent
`java.util.Set<Topic>` | `ScribeImpl.pending` Topics that (should) have an outsanding subscription.
`java.util.Set<Topic>` | `ScribeImpl.roots` Topics that we are the root.
`java.util.Hashtable<Topic,ScribeImpl.TopicManager>` | `ScribeImpl.topicManagers` the hashtable of topic -> TopicManager

Methods in rice.p2p.scribe that return Topic
`Topic` | `ScribeImpl.TopicManager.getTopic()` Gets the topic of the TopicManager object
`Topic[]` | `BaseScribe.getTopics(ScribeClient client)` Deprecated. use getTopicsByClient()
`Topic[]` | `ScribeImpl.getTopics(ScribeClient client)`

Methods in rice.p2p.scribe that return types with arguments of type Topic
`java.util.List<Topic>` | `ScribePolicy.allowSubscribe(Scribe scribe, NodeHandle source, java.util.List<Topic> topics, ScribeContent content)` This method is called when the newChild is about to become our child, and the policy should return whether or not the child should be allowed to become our child.
`java.util.List<Topic>` | `ScribePolicy.DefaultScribePolicy.allowSubscribe(Scribe scribe, NodeHandle source, java.util.List<Topic> topics, ScribeContent content)` If you don't override the deprecated allowSubscribe(), This method always return true;
`java.util.Collection<Topic>` | `ScribeImpl.getTopics()`
`java.util.Collection<Topic>` | `ScribeImpl.getTopicsByChild(NodeHandle child)`
`java.util.Collection<Topic>` | `BaseScribe.getTopicsByClient(ScribeClient client)`
`java.util.Collection<Topic>` | `ScribeImpl.getTopicsByClient(ScribeClient client)` Returns the list of topics the given client is subscribed to.
`java.util.Collection<Topic>` | `BaseScribe.getTopicsByClient(ScribeMultiClient client)`
`java.util.Collection<Topic>` | `ScribeImpl.getTopicsByClient(ScribeMultiClient client)`
`java.util.Collection<Topic>` | `ScribeImpl.getTopicsByParent(NodeHandle parent)`

Methods in rice.p2p.scribe with parameters of type Topic
`void` | `BaseScribe.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 boolean` | `ScribeImpl.addChildHelper(Topic topic, NodeHandle child)` Adds a child to the given topic, using the specified sequence number in the ack message sent to the child.
`protected void` | `ScribeImpl.addToAllChildren(Topic t, NodeHandle child)` This method should be invoked after the state change in the Topic Manager has been made.
`protected void` | `ScribeImpl.addToAllParents(Topic t, NodeHandle parent)`
`boolean` | `ScribeImpl.allParentsContains(Topic t, NodeHandle parent)`
`void` | `ScribeImpl.anycast(Topic topic, RawScribeContent content)`
`void` | `ScribeImpl.anycast(Topic topic, RawScribeContent content, NodeHandle hint)`
`boolean` | `ScribeClient.anycast(Topic topic, ScribeContent content)` Deprecated. 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
`boolean` | `ScribeImpl.ScribeClientConverter.anycast(Topic topic, ScribeContent content)`
`boolean` | `ScribeMultiClient.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, NodeHandle hint)`
`void` | `ScribeClient.childAdded(Topic topic, NodeHandle child)` Deprecated. Informs this client that a child was added to a topic in which it was interested in.
`void` | `ScribeImpl.ScribeClientConverter.childAdded(Topic topic, NodeHandle child)`
`void` | `ScribeMultiClient.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)` Deprecated. Informs this client that a child was removed from a topic in which it was interested in.
`void` | `ScribeImpl.ScribeClientConverter.childRemoved(Topic topic, NodeHandle child)`
`void` | `ScribeMultiClient.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.
`int` | `Topic.compareTo(Topic that)`
`boolean` | `BaseScribe.containsChild(Topic topic, NodeHandle child)`
`boolean` | `ScribeImpl.containsChild(Topic topic, NodeHandle child)`
`boolean` | `BaseScribe.containsTopic(Topic topic)` Returns true if there is a TopicManager object corresponding to this topic
`boolean` | `ScribeImpl.containsTopic(Topic topic)` Returns true if there is a TopicManager associated with this topic (any parent/children/client exists)
`void` | `ScribeClient.deliver(Topic topic, ScribeContent content)` Deprecated. This method is invoked when a message is delivered for a topic this client is interested in.
`void` | `ScribeImpl.ScribeClientConverter.deliver(Topic topic, ScribeContent content)`
`void` | `ScribeMultiClient.deliver(Topic topic, ScribeContent content)` This method is invoked when a message is delivered for a topic this client is interested in.
`NodeHandle[]` | `BaseScribe.getChildren(Topic topic)` Deprecated. use getChildrenOfTopic
`NodeHandle[]` | `ScribeImpl.getChildren(Topic topic)` Returns the list of children for a given topic
`java.util.Collection<NodeHandle>` | `BaseScribe.getChildrenOfTopic(Topic topic)`
`java.util.Collection<NodeHandle>` | `ScribeImpl.getChildrenOfTopic(Topic topic)`
`java.util.Collection<ScribeClient>` | `BaseScribe.getClients(Topic topic)`
`java.util.Collection<ScribeClient>` | `ScribeImpl.getClients(Topic topic)` Returns the list of clients for a given topic
`java.util.Collection<ScribeMultiClient>` | `BaseScribe.getClientsByTopic(Topic topic)`
`java.util.Collection<ScribeMultiClient>` | `ScribeImpl.getClientsByTopic(Topic topic)`
`NodeHandle` | `BaseScribe.getParent(Topic topic)` Returns the parent node for a given topic
`NodeHandle` | `ScribeImpl.getParent(Topic topic)` Returns the parent for a given topic
`java.util.List<Id>` | `ScribeImpl.getPathToRoot(Topic topic)`
`NodeHandle` | `BaseScribe.getRoot(Topic topic)` Returns the root of the topic, if we can determine it.
`NodeHandle` | `ScribeImpl.getRoot(Topic topic)`
`ScribeImpl.TopicManager` | `ScribeImpl.getTopicManager(Topic topic)` Lazy constructor.
`boolean` | `BaseScribe.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
`int` | `BaseScribe.numChildren(Topic topic)`
`int` | `ScribeImpl.numChildren(Topic topic)`
`void` | `ScribeImpl.publish(Topic topic, RawScribeContent content)`
`void` | `ScribeImpl.publish(Topic topic, ScribeContent content)` Publishes the given message to the topic.
`protected void` | `ScribeImpl.recvAnycastFail(Topic topic, NodeHandle failedAtNode, ScribeContent content)`
`void` | `ScribePolicy.recvAnycastFail(Topic topic, NodeHandle failedAtNode, ScribeContent content)` This notifies us when we receive a failure for a anycast
`void` | `ScribePolicy.DefaultScribePolicy.recvAnycastFail(Topic topic, NodeHandle failedAtNode, ScribeContent content)`
`void` | `BaseScribe.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
`protected void` | `ScribeImpl.removeFromAllChildren(Topic t, NodeHandle child)` Need to be holding lock: topicManagers
`protected void` | `ScribeImpl.removeFromAllParents(Topic t, NodeHandle parent)`
`void` | `ScribeImpl.setParent(Topic topic, NodeHandle parent, java.util.List<Id> pathToRoot)`
`void` | `BaseScribe.subscribe(Topic topic, ScribeClient client)` Deprecated. use subscribe(Topic, ScribeMultiClient, ScribeContent, NodeHandle hint)
`void` | `ScribeImpl.subscribe(Topic topic, ScribeClient client)` Subscribes the given client to the provided topic.
`void` | `ScribeImpl.subscribe(Topic topic, ScribeClient client, RawScribeContent content)`
`void` | `ScribeImpl.subscribe(Topic topic, ScribeClient client, RawScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(Topic topic, ScribeClient client, ScribeContent content)`
`void` | `ScribeImpl.subscribe(Topic topic, ScribeClient client, ScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(Topic topic, ScribeMultiClient client)` Subscribes the given client to the provided topic.
`void` | `ScribeImpl.subscribe(Topic topic, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(Topic topic, ScribeMultiClient client, ScribeContent content, NodeHandle hint)`
`void` | `ScribeClient.subscribeFailed(Topic topic)` Deprecated. Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.
`void` | `ScribeImpl.ScribeClientConverter.subscribeFailed(Topic topic)`
`void` | `ScribeMultiClient.subscribeFailed(Topic topic)` Deprecated. use subscribeFailed(Collection topics)
`void` | `BaseScribe.unsubscribe(Topic topic, ScribeClient client)` Deprecated. use unsubscribe(Topic, ScribeMultiClient)
`void` | `ScribeImpl.unsubscribe(Topic topic, ScribeClient client)` Unsubscribes the given client from the provided topic.getId
`void` | `BaseScribe.unsubscribe(Topic topic, ScribeMultiClient client)`
`void` | `ScribeImpl.unsubscribe(Topic topic, ScribeMultiClient client)`

Method parameters in rice.p2p.scribe with type arguments of type Topic
`java.util.List<Topic>` | `ScribePolicy.allowSubscribe(Scribe scribe, NodeHandle source, java.util.List<Topic> topics, ScribeContent content)` This method is called when the newChild is about to become our child, and the policy should return whether or not the child should be allowed to become our child.
`java.util.List<Topic>` | `ScribePolicy.DefaultScribePolicy.allowSubscribe(Scribe scribe, NodeHandle source, java.util.List<Topic> topics, ScribeContent content)` If you don't override the deprecated allowSubscribe(), This method always return true;
`ScribeContent` | `ScribePolicy.divideContent(java.util.List<Topic> theTopics, ScribeContent content)` This method is called when the ScribeImpl splits a SubscribeMessage into multiple parts.
`ScribeContent` | `ScribePolicy.DefaultScribePolicy.divideContent(java.util.List<Topic> theTopics, ScribeContent content)`
`protected void` | `ScribeImpl.doSubscribe(java.util.Collection<Topic> theTopics, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)` This method prevents re-subscription to topics you are already a part of.
`void` | `ScribeImpl.subscribe(java.util.Collection<Topic> topics)`
`void` | `ScribeImpl.subscribe(java.util.Collection<Topic> theTopics, ScribeClient client, RawScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(java.util.Collection<Topic> theTopics, ScribeClient client, ScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(java.util.Collection<Topic> theTopics, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.subscribe(java.util.Collection<Topic> theTopics, ScribeMultiClient client, ScribeContent content, NodeHandle hint)`
`void` | `ScribeImpl.ScribeClientConverter.subscribeFailed(java.util.Collection<Topic> topics)`
`void` | `ScribeMultiClient.subscribeFailed(java.util.Collection<Topic> topics)` Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.
`void` | `ScribeImpl.ScribeClientConverter.subscribeSuccess(java.util.Collection<Topic> topics)`
`void` | `ScribeMultiClient.subscribeSuccess(java.util.Collection<Topic> topics)` Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.
`void` | `BaseScribe.unsubscribe(java.util.Collection<Topic> topicsToUnsubscribe, ScribeMultiClient client)`
`void` | `ScribeImpl.unsubscribe(java.util.Collection<Topic> topicsToUnsubscribe, ScribeMultiClient client)` This code: for each Topic: 1) removes the client from the TopicManager 2)

Uses of Topic in rice.p2p.scribe.javaserialized

Methods in rice.p2p.scribe.javaserialized with parameters of type Topic
`void` | `JavaScribe.anycast(Topic topic, ScribeContent content)` Anycasts the given content to a member of the given topic
`void` | `JavaScribe.anycast(Topic topic, ScribeContent content, NodeHandle hint)` Anycasts the given content to a member of the given topic The hint helps us to implement centralized algorithms where the hint is the cachedRoot for the topic.
`void` | `JavaScribe.publish(Topic topic, ScribeContent content)` Publishes the given message to the topic.
`void` | `JavaScribe.subscribe(Topic topic, ScribeClient client, ScribeContent content)` Deprecated. use subscribe(Topic, ScribeMultiClient, ScribeContent, NodeHandle)
`void` | `JavaScribe.subscribe(Topic topic, ScribeClient client, ScribeContent content, NodeHandle hint)` Deprecated. use the version with the MultiClient
`void` | `JavaScribe.subscribe(Topic topic, ScribeMultiClient client, ScribeContent content, NodeHandle hint)`

Method parameters in rice.p2p.scribe.javaserialized with type arguments of type Topic
`void` | `JavaScribe.subscribe(java.util.Collection<Topic> topics, ScribeClient client, ScribeContent content, NodeHandle hint)` Deprecated. use the version with the MultiClient
`void` | `JavaScribe.subscribe(java.util.Collection<Topic> topics, ScribeMultiClient client, ScribeContent content, NodeHandle hint)`

Uses of Topic in rice.p2p.scribe.maintenance

Methods in rice.p2p.scribe.maintenance that return types with arguments of type Topic
`java.util.Collection<Topic>` | `MaintainableScribe.getTopics()`
`java.util.Collection<Topic>` | `MaintainableScribe.getTopicsByChild(NodeHandle child)` This returns the topics for which the parameter 'child' is a Scribe tree child of the local node
`java.util.Collection<Topic>` | `MaintainableScribe.getTopicsByParent(NodeHandle parent)` This returns the topics for which the parameter 'parent' is a Scribe tree parent of the local node

Methods in rice.p2p.scribe.maintenance with parameters of type Topic
`java.util.List<Id>` | `MaintainableScribe.getPathToRoot(Topic topic)`
`void` | `MaintainableScribe.setParent(Topic topic, NodeHandle parent, java.util.List<Id> pathToRoot)`

Method parameters in rice.p2p.scribe.maintenance with type arguments of type Topic
`RawScribeContent` | `ScribeMaintenancePolicy.implicitSubscribe(java.util.List<Topic> topics)` Called when subscribing for maintenance or tree rearrangement (such as parent death).
`RawScribeContent` | `ScribeMaintenancePolicy.DefaultScribeMaintenancePolicy.implicitSubscribe(java.util.List<Topic> topics)` Called when subscribing for maintenance or tree rearrangement (such as parent death).
`void` | `ScribeMaintenancePolicy.nodeFaulty(MaintainableScribe scribe, NodeHandle node, java.util.List<Topic> nodeWasParent, java.util.List<Topic> nodeWasChild)` When anyone in any Topic (child or parent) is detected faulty.
`void` | `ScribeMaintenancePolicy.nodeFaulty(MaintainableScribe scribe, NodeHandle node, java.util.List<Topic> nodeWasParent, java.util.List<Topic> nodeWasChild)` When anyone in any Topic (child or parent) is detected faulty.
`void` | `ScribeMaintenancePolicy.DefaultScribeMaintenancePolicy.nodeFaulty(MaintainableScribe scribe, NodeHandle handle, java.util.List<Topic> nodeWasParent, java.util.List<Topic> nodeWasChild)`
`void` | `ScribeMaintenancePolicy.DefaultScribeMaintenancePolicy.nodeFaulty(MaintainableScribe scribe, NodeHandle handle, java.util.List<Topic> nodeWasParent, java.util.List<Topic> nodeWasChild)`
`void` | `ScribeMaintenancePolicy.noLongerRoot(MaintainableScribe scribe, java.util.List<Topic> topics)` Called when membership changes "near" the local node, in overlay space.
`void` | `ScribeMaintenancePolicy.DefaultScribeMaintenancePolicy.noLongerRoot(MaintainableScribe scribe, java.util.List<Topic> topics)`
`void` | `MaintainableScribe.subscribe(java.util.Collection<Topic> nodeWasParent, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)`
`void` | `ScribeMaintenancePolicy.subscribeFailed(MaintainableScribe scribe, java.util.List<Topic> failedTopics)` The subscription failed.
`void` | `ScribeMaintenancePolicy.DefaultScribeMaintenancePolicy.subscribeFailed(MaintainableScribe scribe, java.util.List<Topic> failedTopics)`

Uses of Topic in rice.p2p.scribe.messaging

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

Fields in rice.p2p.scribe.messaging with type parameters of type Topic
`protected java.util.List<Topic>` | `AbstractSubscribeMessage.topics` You can now subscribe to a bunch of Topics at the same time.
`protected java.util.Set<Topic>` | `SubscribeLostMessage.topics`

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

Methods in rice.p2p.scribe.messaging that return types with arguments of type Topic
`java.util.List<Topic>` | `AbstractSubscribeMessage.getTopics()`
`java.util.Collection<Topic>` | `SubscribeLostMessage.getTopics()`
`java.util.List<Topic>` | `SubscribeMessage.getTopics()`
`java.util.List<Topic>` | `UnsubscribeMessage.getTopics()` Method which returns this messages' topic

Method parameters in rice.p2p.scribe.messaging with type arguments of type Topic
`SubscribeMessage` | `SubscribeMessage.copy(java.util.List<Topic> newTopics, RawScribeContent content)` Copies everything except changes the topics to the new list
`void` | `SubscribeMessage.removeTopics(java.util.Collection<Topic> accepted)` Call this when you accept topics in the list.
`boolean` | `SubscribeLostMessage.topicsAcked(java.util.Collection<Topic> topic)`

Constructors in rice.p2p.scribe.messaging with parameters of type Topic
`AnycastFailureMessage(NodeHandle source, Topic topic, RawScribeContent content)`
`AnycastFailureMessage(NodeHandle source, Topic topic, ScribeContent content)`
`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
`SubscribeMessage(NodeHandle source, Topic topic, int id, RawScribeContent content)`

Constructor parameters in rice.p2p.scribe.messaging with type arguments of type Topic
`AbstractSubscribeMessage(NodeHandle source, java.util.List<Topic> topics, int id)` Constructor which takes a unique integer Id
`SubscribeAckMessage(NodeHandle source, java.util.List<Topic> topics, java.util.List<java.util.List<Id>> pathsToRoot, int id)` Constructor which takes a unique integer Id
`SubscribeFailedMessage(NodeHandle source, java.util.List<Topic> topics, int id)` Constructor which takes a unique integer Id
`SubscribeLostMessage(NodeHandle source, java.util.Collection<Topic> topics, int id, ScribeMultiClient client)` Constructor which takes a unique integer Id
`SubscribeMessage(NodeHandle source, java.util.List<Topic> topics, int id, RawScribeContent content)` Constructor which takes a unique integer Id
`UnsubscribeMessage(NodeHandle source, java.util.List<Topic> topics)` Constructor which takes a unique integer Id

Uses of Topic in rice.p2p.scribe.rawserialization

Methods in rice.p2p.scribe.rawserialization with parameters of type Topic
`void` | `RawScribe.anycast(Topic topic, RawScribeContent content)` Anycasts the given content to a member of the given topic
`void` | `RawScribe.anycast(Topic topic, RawScribeContent content, NodeHandle hint)` Anycasts the given content to a member of the given topic The hint helps us to implement centralized algorithms where the hint is the cachedRoot for the topic.
`void` | `RawScribe.publish(Topic topic, RawScribeContent content)` Publishes the given message to the topic.
`void` | `RawScribe.subscribe(Topic topic, ScribeClient client, RawScribeContent content)` Deprecated. use subscribe(Topic, ScribeMultiClient, RawScribeContent, NodeHandle)
`void` | `RawScribe.subscribe(Topic topic, ScribeClient client, RawScribeContent content, NodeHandle hint)` Deprecated. use the version with the MultiClient
`void` | `RawScribe.subscribe(Topic topic, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)`

Method parameters in rice.p2p.scribe.rawserialization with type arguments of type Topic
`void` | `RawScribe.subscribe(java.util.Collection<Topic> topics, ScribeClient client, RawScribeContent content, NodeHandle hint)` Deprecated. use the version with the MultiClient
`void` | `RawScribe.subscribe(java.util.Collection<Topic> topics, ScribeMultiClient client, RawScribeContent content, NodeHandle hint)`

Uses of Topic in rice.p2p.scribe.testing

Fields in rice.p2p.scribe.testing declared as Topic
`protected Topic` | `ScribeRegrTest.TestScribeContent.topic` DESCRIBE THE FIELD

Fields in rice.p2p.scribe.testing with type parameters of type Topic
`protected java.util.List<Topic>` | `ScribeRegrTest.TestScribeClient.topics` The topic this client is listening for

Methods in rice.p2p.scribe.testing that return types with arguments of type Topic
`static java.util.List<Topic>` | `ScribeRegrTest.buildListOf1(Topic topic)`

Methods in rice.p2p.scribe.testing with parameters of type Topic
`boolean` | `ScribeRegrTest.TestScribeClient.anycast(Topic topic, ScribeContent content)` DESCRIBE THE METHOD
`static java.util.List<Topic>` | `ScribeRegrTest.buildListOf1(Topic topic)`
`ScribeRegrTest.TestScribeContent` | `RawScribeRegrTest.buildTestScribeContent(Topic topic, int num)`
`ScribeRegrTest.TestScribeContent` | `ScribeRegrTest.buildTestScribeContent(Topic topic, int numMessages)`
`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.deliver(Topic topic, ScribeContent content)` DESCRIBE THE METHOD
`void` | `ScribeRegrTest.TestScribeClient.subscribeFailed(Topic topic)`

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

Constructor parameters in rice.p2p.scribe.testing with type arguments of type Topic
`ScribeRegrTest.TestScribeClient(Scribe scribe, java.util.List<Topic> topics, int i)`

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

Fields in rice.p2p.splitstream with type parameters of type Topic
`protected java.util.Hashtable<Topic,java.lang.Integer>` | `Stripe.failed` The count of failed subscribe messages

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` | `SplitStreamScribePolicy.recvAnycastFail(Topic topic, NodeHandle failedAtNode, ScribeContent content)`
`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.scribe

Methods in rice.tutorial.scribe 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)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV NEXT | FRAMES NO FRAMES

Copyright © 2001-2005 - Rice Pastry.