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)