Home | Trees | Indices | Help |
|
---|
|
object --+ | QueueStore --+ | MemoryQueue
A QueueStore implementation that stores messages in memory.
This classes uses a threading.RLock
to guard access to
the memory store. The locks on this class are probably excessive given
that the coilmq.queue.QueueManager is already implementing
coarse-grained locking on the methods that access this storage backend.
That said, we'll start over-protective and refactor later it if proves
unecessary.
Instance Methods | |||
|
|||
|
|||
stompclient.frame.Frame
|
|
||
int
|
|
||
int
|
|
||
set
|
|
||
Inherited from Inherited from |
Class Variables | |
Inherited from |
Instance Variables | |
Inherited from |
Properties | |
Inherited from |
Method Details |
A base constructor that sets up logging and the lock used by synchronized decorator. If you extend this class, you should either call this method or at minimum make sure these values get set.
|
Store message (frame) for specified destinationination.
|
Removes and returns an item from the queue (or
|
Size of the queue for specified destination.
|
Whether this queue has frames for the specified destination.
|
Provides a list of destinations (queue "addresses") available.
|
Home | Trees | Indices | Help |
|
---|
Generated by Epydoc 3.0.1 on Tue Jun 28 20:30:42 2011 | http://epydoc.sourceforge.net |