diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.h')
-rw-r--r-- | cpp/src/qpid/cluster/Cluster.h | 5 |
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; }; |