From d0b49f4acfb1dfe787289866893197f4cf571955 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 12 Mar 2013 17:15:17 +0000 Subject: 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 --- cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 1 + 1 file changed, 1 insertion(+) (limited to 'cpp/src') 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); } -- cgit v1.2.1