You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2008/05/11 20:33:41 UTC
svn commit: r655353 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Author: gsim
Date: Sun May 11 11:33:41 2008
New Revision: 655353
URL: http://svn.apache.org/viewvc?rev=655353&view=rev
Log:
QPID-1048: Only wait for enqueue completion for persistent queues.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=655353&r1=655352&r2=655353&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Sun May 11 11:33:41 2008
@@ -241,7 +241,7 @@
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;