diff options
| author | Gordon Sim <gsim@apache.org> | 2008-05-11 18:33:41 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-05-11 18:33:41 +0000 |
| commit | 974be95ea8e2770aeb9fadf6a30a053aa127e5ed (patch) | |
| tree | 63e094e10befce00163047b5d10524ca9f4a5a54 /cpp | |
| parent | f131daf74eebcd4630fdf363bc23bba20dc567f4 (diff) | |
| download | qpid-python-974be95ea8e2770aeb9fadf6a30a053aa127e5ed.tar.gz | |
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
Diffstat (limited to 'cpp')
| -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; |