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.h | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'cpp/src/qpid/cluster/Cluster.h') diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h index 2ab2da6fa8..e172a0f180 100644 --- a/cpp/src/qpid/cluster/Cluster.h +++ b/cpp/src/qpid/cluster/Cluster.h @@ -64,11 +64,9 @@ class Cluster : private Cpg::Handler, public management::Manageable { typedef std::vector Connections; /** - * Join a cluster. - * @param name of the cluster. - * @param url of this broker, sent to the cluster. + * Join a cluster. */ - Cluster(const std::string& name, const Url& url, broker::Broker&, bool useQuorum); + Cluster(const std::string& name, const Url& url, broker::Broker&, bool useQuorum, size_t readMax); virtual ~Cluster(); @@ -95,6 +93,8 @@ class Cluster : private Cpg::Handler, public management::Manageable { boost::function isQuorate; void checkQuorum(); + + size_t getReadMax() { return readMax; } private: typedef sys::LockPtr LockPtr; @@ -215,6 +215,7 @@ class Cluster : private Cpg::Handler, public management::Manageable { boost::shared_ptr failoverExchange; Quorum quorum; + size_t readMax; friend std::ostream& operator<<(std::ostream&, const Cluster&); friend class ClusterDispatcher; -- cgit v1.2.1