diff options
| author | Alan Conway <aconway@apache.org> | 2008-09-03 03:21:00 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-09-03 03:21:00 +0000 |
| commit | e8f6b7cd234088e7c33e42eb10e29719ea8e8aa9 (patch) | |
| tree | 2d7df29ebba337fbbe28aa7716f0e32ff9e24c70 /cpp/src/tests/cluster_test.cpp | |
| parent | 05b6583dc0d080d6bc5a0cca09218bb045090daf (diff) | |
| download | qpid-python-e8f6b7cd234088e7c33e42eb10e29719ea8e8aa9.tar.gz | |
Cluster multicasts buffers rather than frames.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@691489 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/cluster_test.cpp')
| -rw-r--r-- | cpp/src/tests/cluster_test.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/cpp/src/tests/cluster_test.cpp b/cpp/src/tests/cluster_test.cpp index 3f09143fff..9abc1b189e 100644 --- a/cpp/src/tests/cluster_test.cpp +++ b/cpp/src/tests/cluster_test.cpp @@ -27,6 +27,7 @@ #include "qpid/client/Connection.h" #include "qpid/client/Session.h" #include "qpid/framing/Uuid.h" +#include "qpid/log/Logger.h" #include <boost/bind.hpp> #include <boost/ptr_container/ptr_vector.hpp> @@ -87,7 +88,7 @@ ClusterFixture::ClusterFixture(size_t n) : name(Uuid(true).str()) { void ClusterFixture::add() { std::ostringstream os; - os << "broker" << size(); + os << "fork" << size(); std::string prefix = os.str(); const char* argv[] = { @@ -105,6 +106,7 @@ void ClusterFixture::add() { } else { // First broker, run in this process. Broker::Options opts; + qpid::log::Logger::instance().setPrefix("main"); Plugin::addOptions(opts); // Pick up cluster options. opts.parse(argc, argv, "", true); // Allow-unknown for --load-module broker0.reset(new BrokerFixture(opts)); @@ -144,7 +146,8 @@ QPID_AUTO_TEST_CASE(testSingletonCluster) { ClusterFixture cluster(1); Client c(cluster[0]); BOOST_CHECK(c.session.queueQuery("q").getQueue().empty()); - BOOST_CHECK(c.session.exchangeQuery("ex").getType().empty()); + BOOST_CHECK(c.session.exchangeQuery("ex").getType().empty()); + // FIXME aconway 2008-09-01: leaks if aisexec not running, investigate. } QPID_AUTO_TEST_CASE(testWiringReplication) { |