|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectist.palcom.pubsub.PubSubManager
public class PubSubManager
A class that manages topic-based publish/subscribe communication.
| Field Summary | |
|---|---|
protected HgraphNode |
_node
|
protected CommunicationManager |
communicationManager
The CommunicationManager used for network communication |
protected PalcomScheduler |
scheduler
|
protected boolean |
started
True while started. |
| Fields inherited from interface ist.palcom.hgraph.IHgraphNode |
|---|
CHILD_NAME_CLASH, CIRCULARITY_CLASH, COMMAND_OR_NODE_MISSING, ERROR, HANDLER_MISSING, INVOKATOR_MISSING, LISTENER_MISSING, NODE_NOT_CHILD, PATH_MISSING, SIBLING_ALREADY_EXISTS, SIBLING_NONEXISTENT, SIBLING_REFERENCE_ALREADY_EXISTS, SIBLING_REFERENCE_NONEXISTENT, STATUS_OK, VALUE_ALREADY_EXISTS, VALUE_NOT_PRESENT |
| Constructor Summary | |
|---|---|
PubSubManager(PalcomScheduler scheduler,
CommunicationManager communicationManager)
|
|
| Method Summary | |
|---|---|
int |
addNodeChild(IHgraphNode node,
Path callerPath)
Adds a child to the node's private list of children. |
java.util.Iterator |
getChildIterator()
|
FuncFunc |
getFuncFunc()
|
java.lang.String |
getNodeName()
hgraph impl below |
IHgraphNode |
getNodeParent()
|
Path |
getPath()
|
SiblingFunc |
getSiblingFunc()
|
ValueFunc |
getValueFunc()
|
boolean |
hasChildNamed(java.lang.String name)
Checks whether the node has a child with a given name |
boolean |
isAncestorOf(IHgraphNode node)
Checks whether this node is an ancestor of the parameter node. |
void |
publish(java.lang.String topic,
Message message)
Publish a message on a topic. |
int |
removeNodeChild(java.lang.String name,
Path callerPath)
Removes a child based on its name. |
int |
setNodeName(java.lang.String name,
Path callerPath)
Sets the name of the node. |
int |
setNodeParent(IHgraphNode newParent,
Path callerPath)
Sets the parent of the HgraphNode. |
void |
stop()
Stops the PubSubManager. |
void |
subscribe(java.lang.String topic,
PalcomThread subscriber)
Subscribe to a topic. |
java.lang.String |
toXML()
|
java.lang.String |
toXMLFull()
|
java.lang.String |
toXMLFullRecursively()
|
java.lang.String |
toXMLRecursively()
|
void |
unsubscribe(java.lang.String topic,
PalcomThread subscriber)
Stop subscribing to a topic. |
void |
updatePath()
Updates the path of the H-Graph node along with its offspring recursively. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected final PalcomScheduler scheduler
protected HgraphNode _node
protected final CommunicationManager communicationManager
protected boolean started
| Constructor Detail |
|---|
public PubSubManager(PalcomScheduler scheduler,
CommunicationManager communicationManager)
| Method Detail |
|---|
public void stop()
public void subscribe(java.lang.String topic,
PalcomThread subscriber)
public void unsubscribe(java.lang.String topic,
PalcomThread subscriber)
public void publish(java.lang.String topic,
Message message)
public java.lang.String getNodeName()
getNodeName in interface IHgraphNode
public int setNodeName(java.lang.String name,
Path callerPath)
IHgraphNode
setNodeName in interface IHgraphNodename - The new name
public Path getPath()
getPath in interface IHgraphNodepublic void updatePath()
IHgraphNode
updatePath in interface IHgraphNodepublic boolean hasChildNamed(java.lang.String name)
IHgraphNode
hasChildNamed in interface IHgraphNodename - The name to check
public boolean isAncestorOf(IHgraphNode node)
IHgraphNode
isAncestorOf in interface IHgraphNode
public int removeNodeChild(java.lang.String name,
Path callerPath)
IHgraphNode
removeNodeChild in interface IHgraphNodename - The name of the child to be removed
public java.lang.String toXML()
toXML in interface IHgraphNodepublic java.lang.String toXMLFull()
toXMLFull in interface IHgraphNodepublic java.lang.String toXMLRecursively()
toXMLRecursively in interface IHgraphNodepublic java.lang.String toXMLFullRecursively()
toXMLFullRecursively in interface IHgraphNode
public int setNodeParent(IHgraphNode newParent,
Path callerPath)
IHgraphNode
setNodeParent in interface IHgraphNodenewParent - the new parent
public int addNodeChild(IHgraphNode node,
Path callerPath)
IHgraphNode
addNodeChild in interface IHgraphNodenode - The new child to be added
public SiblingFunc getSiblingFunc()
getSiblingFunc in interface IHgraphNodepublic ValueFunc getValueFunc()
getValueFunc in interface IHgraphNodepublic FuncFunc getFuncFunc()
getFuncFunc in interface IHgraphNodepublic IHgraphNode getNodeParent()
getNodeParent in interface IHgraphNodepublic java.util.Iterator getChildIterator()
getChildIterator in interface IHgraphNode
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||