1 files changed, 7 insertions, 1 deletions
diff --git a/cpp/src/IceStorm/TopicManagerI.h b/cpp/src/IceStorm/TopicManagerI.h
index 98a9a32da51..aed69de48a9 100644
--- a/cpp/src/IceStorm/TopicManagerI.h
+++ b/cpp/src/IceStorm/TopicManagerI.h
@@ -14,6 +14,7 @@
 
 #include <IceStorm/Replica.h>
 #include <IceStorm/Election.h>
+#include <IceStorm/Instrumentation.h>
 
 #include <IceUtil/RecMutex.h>
 
@@ -35,7 +36,9 @@ typedef IceUtil::Handle<TopicImpl> TopicImplPtr;
 //
 // TopicManager implementation.
 //
-class TopicManagerImpl : public IceStormElection::Replica, public IceUtil::RecMutex
+class TopicManagerImpl : public IceStormElection::Replica,
+                         public IceStorm::Instrumentation::ObserverUpdater,
+                         public IceUtil::RecMutex
 {
 public:
 
@@ -73,6 +76,9 @@ public:
 
 private:
 
+    void updateTopicObservers();
+    void updateSubscriberObservers();
+
     TopicPrx installTopic(const std::string&, const Ice::Identity&, bool,
                           const IceStorm::SubscriberRecordSeq& = IceStorm::SubscriberRecordSeq());