diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerQueue.cpp')
-rw-r--r-- | cpp/src/qpid/broker/BrokerQueue.cpp | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp index 1473ab6288..8ec2064680 100644 --- a/cpp/src/qpid/broker/BrokerQueue.cpp +++ b/cpp/src/qpid/broker/BrokerQueue.cpp @@ -75,6 +75,14 @@ void Queue::process(Message::shared_ptr& msg){ } } +void Queue::requeue(Message::shared_ptr& msg){ + Mutex::ScopedLock locker(lock); + if(queueing || !dispatch(msg)){ + queueing = true; + messages.push_front(msg); + } +} + bool Queue::dispatch(Message::shared_ptr& msg){ if(consumers.empty()){ return false; @@ -163,12 +171,12 @@ uint32_t Queue::purge(){ void Queue::pop(){ if (policy.get()) policy->dequeued(messages.front()->contentSize()); - messages.pop(); + messages.pop_front(); } void Queue::push(Message::shared_ptr& msg){ queueing = true; - messages.push(msg); + messages.push_back(msg); if (policy.get()) { policy->enqueued(msg->contentSize()); if (policy->limitExceeded()) { |