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 | 67d01cee8c0ebdf96c6104942481cecb5b13b810 (patch) | |
| tree | e46d9a0996805edd173c66dc1a574455a750f330 | |
| parent | 2a8826da6293e7d0f0563425141bc21492aab746 (diff) | |
| download | qpid-python-67d01cee8c0ebdf96c6104942481cecb5b13b810.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@1455630 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp index 030b804143..40b09b0fc0 100644 --- a/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp +++ b/qpid/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); } |