OSMQ
v2.0.1

osmq.broker.subqueues
Class TopicalSubscriberQueues

java.lang.Object
  extended byosmq.broker.subqueues.SubscriberQueues
      extended byosmq.broker.subqueues.TopicalSubscriberQueues
All Implemented Interfaces:
java.io.Serializable

public final class TopicalSubscriberQueues
extends SubscriberQueues

Extends SubscriberQueues, adding topical subscription processing.

See Also:
Serialized Form

Constructor Summary
TopicalSubscriberQueues()
           
 
Method Summary
 void addSubscription(java.lang.String topic, java.lang.String subscriber)
          Add a topic subscription for a named subscriber (subscriber's clientID).
 void close()
           
 void distributeAMessage(byte[] o, java.lang.String recipient, java.lang.String topic)
           
 void dropSubscription(java.lang.String topic, java.lang.String subscriber)
          Remove a topic subscription for a named subscriber (subscriber's clientID)
 void dropSubscriptionsFor(java.lang.String subscriber)
           
 java.util.Iterator getSubscriberAndTopicSetIterator()
           
 boolean isLoadTopicsOnCreate()
           
 void reloadTopics()
           
 void setLoadTopicOnCreate(boolean b)
           
 
Methods inherited from class osmq.broker.subqueues.SubscriberQueues
createQueue, findOrCreate, findOrCreateAndLoad, findQueue, getConsolidatedSize, getCurrentFifo, getIterator, getQueueCount, pullFromNamedQueue, put, setAllHaltReads, setAllHaltWrites, setThresholdOverride, size
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicalSubscriberQueues

public TopicalSubscriberQueues()
Method Detail

addSubscription

public void addSubscription(java.lang.String topic,
                            java.lang.String subscriber)
Add a topic subscription for a named subscriber (subscriber's clientID). Creates a queue for the subscriber if one does not exist, and adds the queue to the chain of queues associated with the topic.


dropSubscription

public void dropSubscription(java.lang.String topic,
                             java.lang.String subscriber)
Remove a topic subscription for a named subscriber (subscriber's clientID)


dropSubscriptionsFor

public void dropSubscriptionsFor(java.lang.String subscriber)

distributeAMessage

public void distributeAMessage(byte[] o,
                               java.lang.String recipient,
                               java.lang.String topic)
                        throws java.io.IOException
Throws:
java.io.IOException

setLoadTopicOnCreate

public void setLoadTopicOnCreate(boolean b)

isLoadTopicsOnCreate

public boolean isLoadTopicsOnCreate()

reloadTopics

public void reloadTopics()

getSubscriberAndTopicSetIterator

public final java.util.Iterator getSubscriberAndTopicSetIterator()

close

public void close()

(c) 2000 - 2003 MQue Systems
All Rights Reserved