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

1 files changed, 5 insertions, 4 deletions

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<ConnectionPtr> 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<bool ()> isQuorate;
     void checkQuorum();
+
+    size_t getReadMax() { return readMax; }
     
   private:
     typedef sys::LockPtr<Cluster,sys::Monitor> LockPtr;
@@ -215,6 +215,7 @@ class Cluster : private Cpg::Handler, public management::Manageable {
     boost::shared_ptr<FailoverExchange> failoverExchange;
 
     Quorum quorum;
+    size_t readMax;
 
   friend std::ostream& operator<<(std::ostream&, const Cluster&);
   friend class ClusterDispatcher;