summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Cluster.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.h')
-rw-r--r--cpp/src/qpid/cluster/Cluster.h6
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h
index aff3f18c6d..2a659be2f1 100644
--- a/cpp/src/qpid/cluster/Cluster.h
+++ b/cpp/src/qpid/cluster/Cluster.h
@@ -24,6 +24,7 @@
#include "NoOpConnectionOutputHandler.h"
#include "ClusterMap.h"
#include "FailoverExchange.h"
+#include "Quorum.h"
#include "qpid/broker/Broker.h"
#include "qpid/sys/PollableQueue.h"
@@ -66,7 +67,7 @@ class Cluster : private Cpg::Handler, public management::Manageable {
* @param name of the cluster.
* @param url of this broker, sent to the cluster.
*/
- Cluster(const std::string& name, const Url& url, broker::Broker&);
+ Cluster(const std::string& name, const Url& url, broker::Broker&, bool useQuorum);
virtual ~Cluster();
@@ -176,7 +177,6 @@ class Cluster : private Cpg::Handler, public management::Manageable {
void dumpOutDone(Lock&);
void setClusterId(const framing::Uuid&);
- static bool isQuorateImpl();
mutable sys::Monitor lock;
@@ -215,6 +215,8 @@ class Cluster : private Cpg::Handler, public management::Manageable {
size_t lastSize;
boost::shared_ptr<FailoverExchange> failoverExchange;
+ Quorum quorum;
+
friend std::ostream& operator<<(std::ostream&, const Cluster&);
friend class ClusterDispatcher;
};