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 | 7732bea776f0b7da61b904cc849bb39ba802e6e6 (patch) | |
| tree | 2b9eda40e59deeacf968eb71f806dc104809281a /qpid/cpp/src | |
| parent | 1f2d86d3dd25801f742831901e34317f5623e113 (diff) | |
| download | qpid-python-7732bea776f0b7da61b904cc849bb39ba802e6e6.tar.gz | |
QPID-1048: Only wait for enqueue completion for persistent queues.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@655353 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index dc8c53ccf9..f7bad8ebc6 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/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; |