osmq.broker.subqueues
Class TopicalSubscriberQueues
java.lang.Object
osmq.broker.subqueues.SubscriberQueues
osmq.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
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 |
TopicalSubscriberQueues
public TopicalSubscriberQueues()
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()