1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/cluster/PollableQueue.h b/qpid/cpp/src/qpid/cluster/PollableQueue.h
index 0bba2ba790..29891da344 100644
--- a/qpid/cpp/src/qpid/cluster/PollableQueue.h
+++ b/qpid/cpp/src/qpid/cluster/PollableQueue.h
@@ -90,7 +90,7 @@ template <class T> void PollableQueue<T>::dispatch(sys::DispatchHandle& h) {
     batch.swap(queue);
     condition.clear();
     ScopedUnlock u(lock);
-    callback(batch.begin(), batch.end()); // Process the batch outside the lock.
+    callback(batch.begin(), batch.end()); // Process outside the lock to allow concurrent push.
     h.rewatch();
 }