|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Topic | |
planet.scribe | |
planet.scribe.messaging | |
planet.test.scribe |
Uses of Topic in planet.scribe |
Fields in planet.scribe declared as Topic | |
protected Topic |
ScribeImpl.TopicManager.topic
DESCRIBE THE FIELD |
Methods in planet.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 |
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 |
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 |
Constructors in planet.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 planet.scribe.messaging |
Fields in planet.scribe.messaging declared as Topic | |
protected Topic |
ScribeMessage.topic
|
Methods in planet.scribe.messaging that return Topic | |
Topic |
ScribeMessage.getTopic()
Method which returns this messages' topic |
Constructors in planet.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)
|
|
DropMessage(NodeHandle source,
Topic topic)
|
|
PublishMessage(NodeHandle source,
Topic topic,
ScribeContent content)
|
|
PublishRequestMessage(NodeHandle source,
Topic topic,
ScribeContent content)
|
|
ScribeMessage(NodeHandle source,
Topic topic)
|
|
SubscribeAckMessage(NodeHandle source,
Topic topic,
Id[] pathToRoot,
int id)
|
|
SubscribeFailedMessage(NodeHandle source,
Topic topic,
int id)
Constructor which takes a unique integer Id |
|
SubscribeLostMessage(NodeHandle source,
Topic topic,
int id)
|
|
SubscribeMessage(NodeHandle source,
Topic topic,
int id,
ScribeContent content)
|
|
SubscribeMessage(NodeHandle source,
Topic topic,
Id previousParent,
int id,
ScribeContent content)
Constructor which takes a unique integer Id |
|
UnsubscribeMessage(NodeHandle source,
Topic topic)
|
Uses of Topic in planet.test.scribe |
Methods in planet.test.scribe with parameters of type Topic | |
boolean |
ScribeApplication.anycast(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
void |
ScribeApplication.deliver(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
void |
ScribeApplication.childAdded(Topic topic,
NodeHandle child)
DESCRIBE THE METHOD |
void |
ScribeApplication.childRemoved(Topic topic,
NodeHandle child)
DESCRIBE THE METHOD |
void |
ScribeApplication.subscribeFailed(Topic topic)
|
boolean |
ScribeClientTest.anycast(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
void |
ScribeClientTest.deliver(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
void |
ScribeClientTest.childAdded(Topic topic,
NodeHandle child)
DESCRIBE THE METHOD |
void |
ScribeClientTest.childRemoved(Topic topic,
NodeHandle child)
DESCRIBE THE METHOD |
void |
ScribeClientTest.subscribeFailed(Topic topic)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |