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 | bf192f54d641f1fd84a7213567673c17621d7214 (patch) | |
| tree | f6d7e9c40f75a9f02c17dccd5317d1029b0e78ad /cpp/src/tests/receiver.cpp | |
| parent | 043bd565f3517cd06c1742c6de90ffef30e8bec4 (diff) | |
| download | qpid-python-bf192f54d641f1fd84a7213567673c17621d7214.tar.gz | |
Ack outstanding messages before closing
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751713 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/receiver.cpp')
| -rw-r--r-- | cpp/src/tests/receiver.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/tests/receiver.cpp b/cpp/src/tests/receiver.cpp index 2ea2927b8c..49f7ff0338 100644 --- a/cpp/src/tests/receiver.cpp +++ b/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) |