1 files changed, 7 insertions, 5 deletions

diff --git a/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h b/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
index 31faf4853a..ca92de1e30 100644
--- a/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
+++ b/qpid/cpp/src/qpid/cluster/exp/QueueReplica.h
@@ -50,20 +50,22 @@ struct PrintSubscribers;
 class QueueReplica : public RefCounted
 {
   public:
-    QueueReplica(boost::shared_ptr<broker::Queue> , const MemberId& );
+    QueueReplica(QueueContext&, const MemberId& );
     void subscribe(const MemberId&);
-    void unsubscribe(const MemberId&);
-    void resubscribe(const MemberId&);
+    void unsubscribe(const MemberId&, bool resubscribe);
+    void consumed(const MemberId&,
+                  const framing::SequenceSet& acquired,
+                  const framing::SequenceSet& dequeued);
 
     MemberId getSelf() const { return self; }
 
   private:
     typedef std::deque<MemberId> MemberQueue;
 
-    boost::shared_ptr<broker::Queue> queue;
+    std::string name;
     MemberQueue subscribers;
     MemberId self;
-    boost::intrusive_ptr<QueueContext> context;
+    QueueContext& context;
 
     QueueOwnership getState() const;
     bool isOwner() const;