diff options
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index dc8c53ccf9..f7bad8ebc6 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -241,7 +241,7 @@ bool Queue::consumeNextMessage(QueuedMessage& m, Consumer& c) return false; } else { QueuedMessage msg = messages.front(); - if (!msg.payload->isEnqueueComplete()) { + if (store && !msg.payload->isEnqueueComplete()) { QPID_LOG(debug, "Messages not ready to dispatch on queue '" << name << "'"); addListener(c); return false; |