From ebc7fef02649eda4e245c449146f8911ae730e31 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 25 Feb 2009 11:02:20 +0000 Subject: QPID-1685: Fixed ring queue policy git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747744 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/Queue.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/Queue.cpp') diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 3ae53c8ea9..8c50f26abd 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -676,9 +676,9 @@ bool Queue::enqueue(TransactionContext* ctxt, boost::intrusive_ptr msg) // return true if store exists, bool Queue::dequeue(TransactionContext* ctxt, const QueuedMessage& msg) { - if (policy.get() && !policy->isEnqueued(msg)) return false; { Mutex::ScopedLock locker(messageLock); + if (policy.get() && !policy->isEnqueued(msg)) return false; if (!ctxt) { dequeued(msg); } -- cgit v1.2.1