diff options
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) |