diff options
| author | Gordon Sim <gsim@apache.org> | 2014-07-16 10:19:30 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2014-07-16 10:19:30 +0000 |
| commit | fb07e60dcf073effb49c3a4a32da10145671bdd3 (patch) | |
| tree | 10b0ccc292b322b7a05386864a443dc3c170e8c1 /cpp/src/tests | |
| parent | 7da35bee4c69c74281d47e37dfae08f817e5ac47 (diff) | |
| download | qpid-python-fb07e60dcf073effb49c3a4a32da10145671bdd3.tar.gz | |
QPID-5887: fix to new txtest2, acknowledge messages in the check phase to ensure queues remain drained for any subsequent runs
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1610958 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests')
| -rw-r--r-- | cpp/src/tests/qpid-txtest2.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/tests/qpid-txtest2.cpp b/cpp/src/tests/qpid-txtest2.cpp index a5e3f34a58..6502d1521c 100644 --- a/cpp/src/tests/qpid-txtest2.cpp +++ b/cpp/src/tests/qpid-txtest2.cpp @@ -258,6 +258,7 @@ struct Controller : public Client drained.push_back(msg.getCorrelationId()); ++count; } + session.acknowledge(); receiver.close(); if (!opts.quiet) std::cout << "Drained " << count << " messages from " << *i << std::endl; } |
