diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Queue.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index 3d7b27738f..632e512a32 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -702,8 +702,7 @@ void Queue::enqueueAborted(boost::intrusive_ptr<Message> msg) bool Queue::dequeue(TransactionContext* ctxt, const QueuedMessage& msg) { // FIXME aconway 2011-09-13: new cluster needs tx/dtx support. - if (!ctxt && broker) - if (!broker->getCluster().dequeue(msg)) return false; + if (!ctxt && broker) broker->getCluster().dequeue(msg); ScopedUse u(barrier); if (!u.acquired) return false; |