adding publish adapter

1 files changed, 10 insertions, 6 deletions

diff --git a/cpp/src/IceStorm/Service.cpp b/cpp/src/IceStorm/Service.cpp
index c55eef4fdae..5ba34caa7f6 100644
--- a/cpp/src/IceStorm/Service.cpp
+++ b/cpp/src/IceStorm/Service.cpp
@@ -47,7 +47,8 @@ public:
 private:
 
     TopicManagerIPtr _manager;
-    ObjectAdapterPtr _adapter;
+    ObjectAdapterPtr _topicAdapter;
+    ObjectAdapterPtr _publishAdapter;
 };
 
 } // End namespace IceStorm
@@ -83,18 +84,21 @@ IceStorm::ServiceI::start(const string& name,
     DBPtr dbTopicManager = dbEnv->openDB("topicmanager", true);
 
     TraceLevelsPtr traceLevels = new TraceLevels(name, communicator->getProperties(), communicator->getLogger());
-    _adapter = communicator->createObjectAdapter(name + ".TopicManager");
+    _topicAdapter = communicator->createObjectAdapter(name + ".TopicManager");
+    _publishAdapter = communicator->createObjectAdapter(name + ".Publish");
 
-    _manager = new TopicManagerI(communicator, _adapter, traceLevels, dbEnv, dbTopicManager);
-    _adapter->add(_manager, stringToIdentity(name + "/TopicManager"));
+    _manager = new TopicManagerI(communicator, _topicAdapter, _publishAdapter, traceLevels, dbEnv, dbTopicManager);
+    _topicAdapter->add(_manager, stringToIdentity(name + "/TopicManager"));
 
-    _adapter->activate();
+    _topicAdapter->activate();
+    _publishAdapter->activate();
 }
 
 void
 IceStorm::ServiceI::stop()
 {
-    _adapter->deactivate();
+    _topicAdapter->deactivate();
+    _publishAdapter->deactivate();
 
     //
     // It's necessary to reap all destroyed topics on shutdown.