You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/07/16 12:19:30 UTC
svn commit: r1610958 - /qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp
Author: gsim
Date: Wed Jul 16 10:19:30 2014
New Revision: 1610958
URL: http://svn.apache.org/r1610958
Log:
QPID-5887: fix to new txtest2, acknowledge messages in the check phase to ensure queues remain drained for any subsequent runs
Modified:
qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp
Modified: qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp?rev=1610958&r1=1610957&r2=1610958&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/qpid-txtest2.cpp Wed Jul 16 10:19:30 2014
@@ -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;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org