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.h5
1 files changed, 4 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h
index b37a1e343b..55358e25db 100644
--- a/cpp/src/qpid/cluster/Cluster.h
+++ b/cpp/src/qpid/cluster/Cluster.h
@@ -77,7 +77,7 @@ class Cluster : private Cpg::Handler, public management::Manageable
/** Send to the cluster */
void mcastControl(const framing::AMQBody& controlBody, Connection* cptr);
- void mcastBuffer(const char*, size_t, const ConnectionId&);
+ void mcastBuffer(const char*, size_t, const ConnectionId&, size_t id);
void mcastEvent(const Event& e);
/** Leave the cluster */
@@ -89,6 +89,7 @@ class Cluster : private Cpg::Handler, public management::Manageable
void ready(const MemberId&, const std::string& url);
MemberId getSelf() const { return self; }
+ MemberId getId() const { return self; }
void ready();
void stall();
@@ -169,6 +170,8 @@ class Cluster : private Cpg::Handler, public management::Manageable
JoiningHandler joiningHandler;
MemberHandler memberHandler;
+ size_t mcastId;
+
friend class JoiningHandler;
friend class MemberHandler;
};