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 | c2e9cb0f73de96b620c61c4109ab136a96764a82 (patch) | |
| tree | 97b31eef26e33b4f77990e1a48c2a2ae7e751f35 /qpid/cpp/src | |
| parent | de1ec0610d7dfc789a4fd9dadf8cd479d48478c1 (diff) | |
| download | qpid-python-c2e9cb0f73de96b620c61c4109ab136a96764a82.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@1610958 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/tests/qpid-txtest2.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/qpid-txtest2.cpp b/qpid/cpp/src/tests/qpid-txtest2.cpp index a5e3f34a58..6502d1521c 100644 --- a/qpid/cpp/src/tests/qpid-txtest2.cpp +++ b/qpid/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; } |