diff options
| author | Gordon Sim <gsim@apache.org> | 2009-12-15 09:50:30 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2009-12-15 09:50:30 +0000 |
| commit | 17450dde553efb74e549493391288af5ee2b6e3b (patch) | |
| tree | 53da99b815b0a2ac8aafc2741a32ea321689574b /cpp/src/qpid/broker/SemanticState.cpp | |
| parent | 3baba3c1462930d78662492e0a083d63822b33d0 (diff) | |
| download | qpid-python-17450dde553efb74e549493391288af5ee2b6e3b.tar.gz | |
QPID-2089: Dequeue on acquire for accept mode NONE
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@890721 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticState.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp index 9680ada936..4502ff9f32 100644 --- a/cpp/src/qpid/broker/SemanticState.cpp +++ b/cpp/src/qpid/broker/SemanticState.cpp @@ -311,7 +311,7 @@ bool SemanticState::ConsumerImpl::deliver(QueuedMessage& msg) bool sync = syncFrequency && ++deliveryCount >= syncFrequency; if (sync) deliveryCount = 0;//reset parent->deliver(record, sync); - if (!ackExpected) record.setEnded();//allows message to be released now its been delivered + if (!ackExpected && acquire) record.setEnded();//allows message to be released now its been delivered if (windowing || ackExpected || !acquire) { parent->record(record); } |