diff options
| author | Gordon Sim <gsim@apache.org> | 2013-03-12 17:15:17 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-03-12 17:15:17 +0000 |
| commit | d0b49f4acfb1dfe787289866893197f4cf571955 (patch) | |
| tree | a97e0bed4955cfe74f0ea6c3069b88fd2bdb1a6c /cpp/src | |
| parent | 8e88517214a3ee2dee3275074a4463264b6b6208 (diff) | |
| download | qpid-python-d0b49f4acfb1dfe787289866893197f4cf571955.tar.gz | |
QPID-4595: ensure completions for previously received messages are sent when credit is flushed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1455630 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp index 030b804143..40b09b0fc0 100644 --- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp +++ b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp @@ -183,6 +183,7 @@ bool ReceiverImpl::fetchImpl(qpid::messaging::Message& message, qpid::messaging: { sys::Mutex::ScopedLock l(lock); startFlow(l); //reallocate credit + session.sendCompletion();//ensure previously received messages are signalled as completed } return getImpl(message, Duration::IMMEDIATE); } |