|
ePOST 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.post | |
rice.post.delivery | |
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,
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,
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,
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,
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,
Id previousParent,
int id,
ScribeContent content)
Constructor which takes a unique integer Id |
|
SubscribeMessage(NodeHandle source,
Topic topic,
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.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 |
ScribeRegrTest.TestScribeClient.anycast(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.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 | |
---|---|
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.post |
---|
Methods in rice.post with parameters of type Topic | |
---|---|
boolean |
PostImpl.anycast(Topic topic,
ScribeContent content)
This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
PostImpl.childAdded(Topic topic,
NodeHandle child)
Informs this client that a child was added to a topic in which it was interested in. |
void |
PostImpl.childRemoved(Topic topic,
NodeHandle child)
Informs this client that a child was removed from a topic in which it was interested in. |
void |
PostImpl.deliver(Topic topic,
ScribeContent content)
Method by which Scribe delivers a message to this client. |
void |
PostImpl.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.post.delivery |
---|
Methods in rice.post.delivery with parameters of type Topic | |
---|---|
boolean |
DeliveryService.anycast(Topic topic,
ScribeContent content)
This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
DeliveryService.childAdded(Topic topic,
NodeHandle child)
Informs this client that a child was added to a topic in which it was interested in. |
void |
DeliveryService.childRemoved(Topic topic,
NodeHandle child)
Informs this client that a child was removed from a topic in which it was interested in. |
void |
DeliveryService.deliver(Topic topic,
ScribeContent content)
Method by which Scribe delivers a message to this client. |
void |
DeliveryService.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.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)
|
|
ePOST API | |||||||||
PREV NEXT | FRAMES NO FRAMES |