diff options
Diffstat (limited to 'cpp/src/qpid/ha/QueueReplicator.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/QueueReplicator.cpp | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/cpp/src/qpid/ha/QueueReplicator.cpp b/cpp/src/qpid/ha/QueueReplicator.cpp index 7c65ea3522..af987a1e5e 100644 --- a/cpp/src/qpid/ha/QueueReplicator.cpp +++ b/cpp/src/qpid/ha/QueueReplicator.cpp @@ -144,11 +144,9 @@ template <class T> T decodeContent(Message& m) { void QueueReplicator::dequeue(SequenceNumber n, sys::Mutex::ScopedLock&) { // Thread safe: only calls thread safe Queue functions. - if (queue->getPosition() >= n) { // Ignore messages we haven't reached yet - QueuedMessage message; - if (queue->acquireMessageAt(n, message)) - queue->dequeue(0, message); - } + QueuedMessage message; + if (queue->acquireMessageAt(n, message)) + queue->dequeue(0, message); } // Called in connection thread of the queues bridge to primary. |