OSMQ
v2.0.1

osmq.broker.subqueues
Class TopicSubscriptions

java.lang.Object
  extended byosmq.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.


Constructor Summary
TopicSubscriptions()
           
TopicSubscriptions(java.lang.String poolname)
           
 
Method Summary
 void addSubscription(MQue value, java.lang.String topic)
           
 void close()
           
 int distributeAMessage(java.lang.String topic, byte[] byteMessage)
           
 java.util.Vector getBuildSubscribersToTopic(java.lang.String topic)
           
 java.lang.String getFileName()
           
 java.util.Iterator getIteratorOfTopics()
           
 java.util.Iterator getSubscriberAndTopicSetIterator()
           
 java.util.Iterator getSubscribersToTopic(java.lang.String topic)
           
 int getTopicCount()
           
 void removeSubscription(MQue value, java.lang.String topic)
           
 void removeTopic(java.lang.String topic)
           
 void saveTopicSets(java.lang.String filename)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicSubscriptions

public TopicSubscriptions()

TopicSubscriptions

public TopicSubscriptions(java.lang.String poolname)
Method Detail

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)

(c) 2000 - 2003 MQue Systems
All Rights Reserved