diff options
| author | Gordon Sim <gsim@apache.org> | 2009-03-09 15:50:48 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2009-03-09 15:50:48 +0000 |
| commit | d469138f93d94e6ebea42e0111abf8ad452cc9c9 (patch) | |
| tree | b3c413f3f3e0333c8e6a6b424b698417e718caeb /qpid/cpp | |
| parent | d88ca1b36ba61b24b3a6980583593c9f3997c0f9 (diff) | |
| download | qpid-python-d469138f93d94e6ebea42e0111abf8ad452cc9c9.tar.gz | |
Ack outstanding messages before closing
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@751713 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
| -rw-r--r-- | qpid/cpp/src/tests/receiver.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/receiver.cpp b/qpid/cpp/src/tests/receiver.cpp index 2ea2927b8c..49f7ff0338 100644 --- a/qpid/cpp/src/tests/receiver.cpp +++ b/qpid/cpp/src/tests/receiver.cpp @@ -110,6 +110,9 @@ void Receiver::execute(AsyncSession& session, bool /*isRetry*/) SubscriptionManager subs(session); subscription = subs.subscribe(*this, queue, settings); subs.run(); + if (settings.autoAck) { + subscription.accept(subscription.getUnaccepted()); + } } int main(int argc, char ** argv) |