From fb0ed749558c97795571cb56f394a983fd13f8ce Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 14 Feb 2011 14:07:14 +0000 Subject: QPID-3053: Enable broadcast via QMFv2 by default; add option to allow broadcast over QMFv1 to be independently controlled. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1070491 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/Broker.cpp | 8 +++++--- cpp/src/qpid/broker/Broker.h | 1 + 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp index 0cc150419f..cb301916c2 100644 --- a/cpp/src/qpid/broker/Broker.cpp +++ b/cpp/src/qpid/broker/Broker.cpp @@ -102,7 +102,8 @@ Broker::Options::Options(const std::string& name) : requireEncrypted(false), maxSessionRate(0), asyncQueueEvents(false), // Must be false in a cluster. - qmf2Support(false) + qmf2Support(true), + qmf1Support(true) { int c = sys::SystemInfo::concurrency(); workerThreads=c+1; @@ -122,7 +123,8 @@ Broker::Options::Options(const std::string& name) : ("max-connections", optValue(maxConnections, "N"), "Sets the maximum allowed connections") ("connection-backlog", optValue(connectionBacklog, "N"), "Sets the connection backlog limit for the server socket") ("mgmt-enable,m", optValue(enableMgmt,"yes|no"), "Enable Management") - ("mgmt-qmf2", optValue(qmf2Support,"yes|no"), "Use QMF v2 for Broker Management") + ("mgmt-qmf2", optValue(qmf2Support,"yes|no"), "Enable broadcast of management information over QMF v2") + ("mgmt-qmf1", optValue(qmf1Support,"yes|no"), "Enable broadcast of management information over QMF v1") ("mgmt-pub-interval", optValue(mgmtPubInterval, "SECONDS"), "Management Publish Interval") ("queue-purge-interval", optValue(queueCleanInterval, "SECONDS"), "Interval between attempts to purge any expired messages from queues") @@ -148,7 +150,7 @@ const std::string knownHostsNone("none"); Broker::Broker(const Broker::Options& conf) : poller(new Poller), config(conf), - managementAgent(conf.enableMgmt ? new ManagementAgent(!conf.qmf2Support, + managementAgent(conf.enableMgmt ? new ManagementAgent(conf.qmf1Support, conf.qmf2Support) : 0), store(new NullMessageStore), diff --git a/cpp/src/qpid/broker/Broker.h b/cpp/src/qpid/broker/Broker.h index 32e2c8ab6b..cd6f81dc70 100644 --- a/cpp/src/qpid/broker/Broker.h +++ b/cpp/src/qpid/broker/Broker.h @@ -115,6 +115,7 @@ public: uint32_t maxSessionRate; bool asyncQueueEvents; bool qmf2Support; + bool qmf1Support; private: std::string getHome(); -- cgit v1.2.1