Dump shared state to new cluster members.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@696788 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 1 deletions

diff --git a/cpp/src/qpid/cluster/ClusterHandler.h b/cpp/src/qpid/cluster/ClusterHandler.h
index 5da5cf5b75..95106de016 100644
--- a/cpp/src/qpid/cluster/ClusterHandler.h
+++ b/cpp/src/qpid/cluster/ClusterHandler.h
@@ -24,6 +24,7 @@
 
 #include "Cpg.h"
 #include "types.h"
+#include <boost/intrusive_ptr.hpp>
 
 namespace qpid {
 
@@ -31,6 +32,7 @@ namespace framing { class AMQFrame; }
 
 namespace cluster {
 
+class Connection;
 class Cluster;
 class Event;
 
@@ -44,6 +46,8 @@ class ClusterHandler
     ClusterHandler(Cluster& c);
     virtual ~ClusterHandler();
 
+    bool invoke(const MemberId&, framing::AMQFrame& f);
+
     virtual void update(const MemberId&, const framing::FieldTable& members, uint64_t dumping) = 0;
     virtual void dumpRequest(const MemberId&, const std::string& url) = 0;
     virtual void ready(const MemberId&, const std::string& url) = 0;
@@ -54,7 +58,7 @@ class ClusterHandler
                               cpg_address *left, int nLeft,
                               cpg_address *joined, int nJoined) = 0;
 
-    bool invoke(const MemberId&, framing::AMQFrame& f);
+    virtual void insert(const boost::intrusive_ptr<Connection>& c) = 0;
 
   protected:
     Cluster& cluster;