summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/ha/QueueReplicator.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/ha/QueueReplicator.cpp')
-rw-r--r--cpp/src/qpid/ha/QueueReplicator.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/ha/QueueReplicator.cpp b/cpp/src/qpid/ha/QueueReplicator.cpp
index efa45ff58c..7c65ea3522 100644
--- a/cpp/src/qpid/ha/QueueReplicator.cpp
+++ b/cpp/src/qpid/ha/QueueReplicator.cpp
@@ -159,6 +159,7 @@ void QueueReplicator::route(Deliverable& msg)
sys::Mutex::ScopedLock l(lock);
if (!isEventKey(key)) {
msg.deliverTo(queue);
+ // FIXME aconway 2012-06-10: race, position may have moved
QPID_LOG(trace, logPrefix << "Enqueued message " << queue->getPosition());
}
else if (key == DEQUEUE_EVENT_KEY) {