From 67d01cee8c0ebdf96c6104942481cecb5b13b810 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@1455630 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 1 + 1 file changed, 1 insertion(+) 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); } -- cgit v1.2.1