diff options
Diffstat (limited to 'cpp/src/IceStorm/TopicManagerI.cpp')
| -rw-r--r-- | cpp/src/IceStorm/TopicManagerI.cpp | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/cpp/src/IceStorm/TopicManagerI.cpp b/cpp/src/IceStorm/TopicManagerI.cpp index 7aef0b56252..fe9ef2c88d6 100644 --- a/cpp/src/IceStorm/TopicManagerI.cpp +++ b/cpp/src/IceStorm/TopicManagerI.cpp @@ -12,7 +12,6 @@ #include <IceStorm/SubscriberPool.h> #include <IceStorm/BatchFlusher.h> #include <IceStorm/TraceLevels.h> -#include <IceStorm/KeepAliveThread.h> #include <IceStorm/Instance.h> #include <Freeze/Initialize.h> @@ -35,8 +34,7 @@ TopicManagerI::TopicManagerI( _envName(envName), _dbName(dbName), _connection(Freeze::createConnection(instance->communicator(), envName)), - _topics(_connection, dbName), - _upstream(_connection, "upstream") + _topics(_connection, dbName) { // // Recreate each of the topics in the persistent map @@ -62,7 +60,6 @@ TopicManagerI::create(const string& name, const Ice::Current&) } _topics.put(PersistentTopicMap::value_type(name, LinkRecordDict())); - _upstream.put(PersistentUpstreamMap::value_type(name, TopicUpstreamLinkPrxSeq())); installTopic(name, LinkRecordDict(), true); // @@ -157,8 +154,6 @@ TopicManagerI::reap() _topics.erase(i->first); - _upstream.erase(i->first); - try { Ice::Identity id; |