diff options
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 3bde07c4d6..213a36d59d 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -65,6 +65,7 @@ namespace qpid { typedef std::list<Consumer::shared_ptr> Listeners; typedef std::deque<QueuedMessage> Messages; + typedef std::map<string,QueuedMessage*> LVQ; const string name; const bool autodelete; @@ -81,6 +82,7 @@ namespace qpid { std::vector<std::string> traceExclude; Listeners listeners; Messages messages; + LVQ lvq; mutable qpid::sys::Mutex consumerLock; mutable qpid::sys::Mutex messageLock; mutable qpid::sys::Mutex ownershipLock; @@ -253,6 +255,9 @@ namespace qpid { } bool releaseMessageContent(const QueuedMessage&); + + void popMsg(QueuedMessage& qmsg); + }; } } |