|
OSMQ v2.0.1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectosmq.broker.subqueues.SubscriberQueues
Multi-queue object, where each queue is identified by a unique string key value. If a queue is searched and not found, a new queue related to the string value is instantiated. Queues are never destroyed -- they are closed. This class is never instantiated, but is the base class to the Topical SubscriberQueues.
Constructor Summary | |
SubscriberQueues()
|
Method Summary | |
SubscriberQueue |
createQueue(java.lang.String key)
Unconditionally creates a name Queue associated with the value key. |
SubscriberQueue |
findOrCreate(java.lang.String key)
Return the Queue associated with a key. |
SubscriberQueue |
findOrCreateAndLoad(java.lang.String key)
Return the Queue associated with a key. |
SubscriberQueue |
findQueue(java.lang.String key)
Locate a Queue associated with the value key. |
QueueStats |
getConsolidatedSize(QueueStats counts)
Return the consolidated number of element contained in all the queues contained in the set. |
SubscriberQueue |
getCurrentFifo(java.lang.String key)
|
java.util.Iterator |
getIterator()
|
int |
getQueueCount()
|
byte[] |
pullFromNamedQueue(java.lang.String key)
Get the next message value from the queue associated with a key value. |
void |
put(byte[] value,
java.lang.String key)
Puts a value onto a named Queue. |
void |
setAllHaltReads(boolean halt)
|
void |
setAllHaltWrites(boolean halt)
|
void |
setThresholdOverride(int thresholdoverride)
|
long |
size(java.lang.String key)
|
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SubscriberQueues()
Method Detail |
public final void setThresholdOverride(int thresholdoverride)
public final void put(byte[] value, java.lang.String key) throws java.io.IOException
java.io.IOException
public final byte[] pullFromNamedQueue(java.lang.String key) throws java.io.IOException
java.io.IOException
public final long size(java.lang.String key)
public final java.util.Iterator getIterator()
public final void setAllHaltReads(boolean halt)
public final void setAllHaltWrites(boolean halt)
public final QueueStats getConsolidatedSize(QueueStats counts)
public final int getQueueCount()
public final SubscriberQueue getCurrentFifo(java.lang.String key)
public SubscriberQueue findOrCreateAndLoad(java.lang.String key)
If a new Queue is created, look for a file with a corresponding name. If one is found, load the values from that file into the Queue
public SubscriberQueue findOrCreate(java.lang.String key)
public SubscriberQueue createQueue(java.lang.String key)
public SubscriberQueue findQueue(java.lang.String key)
|
(c) 2000 - 2003 MQue Systems All Rights Reserved |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |