diff options
Diffstat (limited to 'cpp/src/qpid/broker/PriorityQueue.h')
-rw-r--r-- | cpp/src/qpid/broker/PriorityQueue.h | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/PriorityQueue.h b/cpp/src/qpid/broker/PriorityQueue.h index 4bf9d26a9d..67c31468d2 100644 --- a/cpp/src/qpid/broker/PriorityQueue.h +++ b/cpp/src/qpid/broker/PriorityQueue.h @@ -40,16 +40,13 @@ class PriorityQueue : public Messages PriorityQueue(int levels); virtual ~PriorityQueue() {} size_t size(); - bool empty(); - void reinsert(const QueuedMessage&); - bool remove(const framing::SequenceNumber&, QueuedMessage&); + bool deleted(const QueuedMessage&); + void release(const QueuedMessage&); + bool acquire(const framing::SequenceNumber&, QueuedMessage&); bool find(const framing::SequenceNumber&, QueuedMessage&); - bool next(const framing::SequenceNumber&, QueuedMessage&); - - QueuedMessage& front(); - void pop(); - bool pop(QueuedMessage&); + bool browse(const framing::SequenceNumber&, QueuedMessage&, bool); + bool consume(QueuedMessage&); bool push(const QueuedMessage& added, QueuedMessage& removed); void foreach(Functor); |