From e8f6b7cd234088e7c33e42eb10e29719ea8e8aa9 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 3 Sep 2008 03:21:00 +0000 Subject: 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 --- cpp/src/tests/cluster_test.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'cpp/src/tests/cluster_test.cpp') 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 #include @@ -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) { -- cgit v1.2.1