From 2379dcbd554ab5c1aac616b5585c99e3d742305e Mon Sep 17 00:00:00 2001
From: Benoit Foucher <benoit@zeroc.com>
Date: Fri, 21 Jul 2006 14:30:52 +0000
Subject: Initial implementation of the IceGrid registry replication.

---
 cpp/src/IceGrid/Topics.h | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'cpp/src/IceGrid/Topics.h')

diff --git a/cpp/src/IceGrid/Topics.h b/cpp/src/IceGrid/Topics.h
index 385ca475be3..2101fa41c4a 100644
--- a/cpp/src/IceGrid/Topics.h
+++ b/cpp/src/IceGrid/Topics.h
@@ -23,7 +23,7 @@ class NodeObserverTopic : public NodeObserver, public IceUtil::Mutex
 {
 public:
 
-    NodeObserverTopic(const IceStorm::TopicManagerPrx&);
+    NodeObserverTopic(const Ice::ObjectAdapterPtr&, const IceStorm::TopicManagerPrx&);
 
     virtual void init(const NodeDynamicInfoSeq&, const Ice::Current&);
     virtual void nodeUp(const NodeDynamicInfo&, const Ice::Current&);
@@ -33,12 +33,14 @@ public:
 
     void subscribe(const NodeObserverPrx&, int serial = -1);
     void unsubscribe(const NodeObserverPrx&);
+    const NodeObserverPrx& getPublisher() { return _publisher; }
 
     void removeNode(const std::string&);
 
 private:
 
     const IceStorm::TopicPrx _topic;
+    const NodeObserverPrx _internalPublisher;
     const NodeObserverPrx _publisher;
 
     int _serial;
@@ -50,7 +52,7 @@ class RegistryObserverTopic : public RegistryObserver, public IceUtil::Monitor<I
 {
 public:
 
-    RegistryObserverTopic(const IceStorm::TopicManagerPrx&);
+    RegistryObserverTopic(const Ice::ObjectAdapterPtr&, const IceStorm::TopicManagerPrx&);
     virtual void init(int, const ApplicationDescriptorSeq&, const AdapterInfoSeq&, const ObjectInfoSeq&,
 		      const Ice::Current&);
 
@@ -68,12 +70,14 @@ public:
 
     void subscribe(const RegistryObserverPrx&, int = -1);
     void unsubscribe(const RegistryObserverPrx&);
+    const RegistryObserverPrx& getPublisher() { return _publisher; }
 
 private:
 
     void updateSerial(int);
 
     const IceStorm::TopicPrx _topic;
+    const RegistryObserverPrx _internalPublisher;
     const RegistryObserverPrx _publisher;
 
     int _serial;
-- 
cgit v1.2.3