From 854d7472c441248cefa783a34606c5ba8bf053ec Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 9 Dec 2008 20:08:47 +0000 Subject: Cluster: Option --cluster-read-max configures read-to-redeliver flow-control. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724857 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Cluster.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'cpp/src/qpid/cluster/Cluster.cpp') diff --git a/cpp/src/qpid/cluster/Cluster.cpp b/cpp/src/qpid/cluster/Cluster.cpp index 602933b88b..8d9b5a1864 100644 --- a/cpp/src/qpid/cluster/Cluster.cpp +++ b/cpp/src/qpid/cluster/Cluster.cpp @@ -85,7 +85,7 @@ struct ClusterDispatcher : public framing::AMQP_AllOperations::ClusterHandler { bool invoke(AMQBody& body) { return framing::invoke(*this, body).wasHandled(); } }; -Cluster::Cluster(const std::string& name_, const Url& url_, broker::Broker& b, bool useQuorum) : +Cluster::Cluster(const std::string& name_, const Url& url_, broker::Broker& b, bool quorum_, size_t readMax_) : broker(b), poller(b.getPoller()), cpg(*this), @@ -104,7 +104,8 @@ Cluster::Cluster(const std::string& name_, const Url& url_, broker::Broker& b, b mgmtObject(0), state(INIT), lastSize(0), - lastBroker(false) + lastBroker(false), + readMax(readMax_) { ManagementAgent* agent = ManagementAgent::Singleton::getInstance(); if (agent != 0){ @@ -119,7 +120,7 @@ Cluster::Cluster(const std::string& name_, const Url& url_, broker::Broker& b, b deliverQueue.start(); mcastQueue.start(); QPID_LOG(notice, *this << " joining cluster " << name << " with url=" << myUrl); - if (useQuorum) quorum.init(); + if (quorum_) quorum.init(); cpg.join(name); broker.addFinalizer(boost::bind(&Cluster::brokerShutdown, this)); // Must be last for exception safety. } -- cgit v1.2.1