osmq.broker.subqueues
Class TopicSubscriptions
java.lang.Object
osmq.broker.subqueues.TopicSubscriptions
- public class TopicSubscriptions
- extends java.lang.Object
Used to associate a topic with one or more subscribers.
The subscriber object may be a fifo (used by the message broker)
This is an aggregate member of TopicalSubscriberQueues.
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicSubscriptions
public TopicSubscriptions()
TopicSubscriptions
public TopicSubscriptions(java.lang.String poolname)
addSubscription
public final void addSubscription(MQue value,
java.lang.String topic)
removeSubscription
public final void removeSubscription(MQue value,
java.lang.String topic)
removeTopic
public final void removeTopic(java.lang.String topic)
getIteratorOfTopics
public final java.util.Iterator getIteratorOfTopics()
getTopicCount
public final int getTopicCount()
distributeAMessage
public final int distributeAMessage(java.lang.String topic,
byte[] byteMessage)
throws java.io.IOException
- Throws:
java.io.IOException
getSubscriberAndTopicSetIterator
public final java.util.Iterator getSubscriberAndTopicSetIterator()
saveTopicSets
public final void saveTopicSets(java.lang.String filename)
throws java.io.IOException
- Throws:
java.io.IOException
close
public void close()
getBuildSubscribersToTopic
public final java.util.Vector getBuildSubscribersToTopic(java.lang.String topic)
getFileName
public final java.lang.String getFileName()
getSubscribersToTopic
public final java.util.Iterator getSubscribersToTopic(java.lang.String topic)