Abstract base class for queue storage.
Extensions/implementations of this class must be thread-safe.
|
|
__init__(self)
A base constructor that sets up logging and the lock used by
synchronized decorator. |
|
|
|
|
enqueue(self,
destination,
frame)
Store message (frame) for specified destinationination. |
|
|
stompclient.frame.Frame
|
dequeue(self,
destination)
Removes and returns an item from the queue (or None if
no items in queue). |
|
|
|
|
requeue(self,
destination,
frame)
Requeue a message (frame) for storing at specified
destinationination. |
|
|
int
|
size(self,
destination)
Size of the queue for specified destination. |
|
|
int
|
has_frames(self,
destination)
Whether specified destination has any frames. |
|
|
set
|
destinations(self)
Provides a set of destinations (queue "addresses")
available. |
|
|
|
|
close(self)
May be implemented to perform any necessary cleanup operations when
store is closed. |
|
|
|
|
frames(self,
destination)
Returns an iterator for frames in specified queue. |
|
|
|
Inherited from object:
__delattr__,
__format__,
__getattribute__,
__hash__,
__new__,
__reduce__,
__reduce_ex__,
__repr__,
__setattr__,
__sizeof__,
__str__,
__subclasshook__
|