From 974be95ea8e2770aeb9fadf6a30a053aa127e5ed Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Sun, 11 May 2008 18:33:41 +0000 Subject: QPID-1048: Only wait for enqueue completion for persistent queues. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655353 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/Queue.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/Queue.cpp') 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; -- cgit v1.2.1