diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/MessageMap.h')
-rw-r--r-- | qpid/cpp/src/qpid/broker/MessageMap.h | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/broker/MessageMap.h b/qpid/cpp/src/qpid/broker/MessageMap.h index 1128a1d54a..d1b8217f9b 100644 --- a/qpid/cpp/src/qpid/broker/MessageMap.h +++ b/qpid/cpp/src/qpid/broker/MessageMap.h @@ -43,14 +43,12 @@ class MessageMap : public Messages size_t size(); bool empty(); - void reinsert(const QueuedMessage&); - virtual bool remove(const framing::SequenceNumber&, QueuedMessage&); + bool deleted(const QueuedMessage&); + void release(const QueuedMessage&); + virtual bool acquire(const framing::SequenceNumber&, QueuedMessage&); bool find(const framing::SequenceNumber&, QueuedMessage&); - virtual bool next(const framing::SequenceNumber&, QueuedMessage&); - - QueuedMessage& front(); - void pop(); - bool pop(QueuedMessage&); + virtual bool browse(const framing::SequenceNumber&, QueuedMessage&, bool); + bool consume(QueuedMessage&); virtual bool push(const QueuedMessage& added, QueuedMessage& removed); void foreach(Functor); |