1 files changed, 59 insertions, 0 deletions
diff --git a/cpp/src/IceStorm/TransientTopicManagerI.h b/cpp/src/IceStorm/TransientTopicManagerI.h
new file mode 100644
index 00000000000..ca781bf451b
--- /dev/null
+++ b/cpp/src/IceStorm/TransientTopicManagerI.h
@@ -0,0 +1,59 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2007 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+#ifndef TRANSIENT_TOPIC_MANAGER_I_H
+#define TRANSIENT_TOPIC_MANAGER_I_H
+
+#include <IceStorm/IceStormInternal.h>
+
+namespace IceStorm
+{
+
+//
+// Forward declarations.
+//
+class Instance;
+typedef IceUtil::Handle<Instance> InstancePtr;
+
+class TransientTopicImpl;
+typedef IceUtil::Handle<TransientTopicImpl> TransientTopicImplPtr;
+
+//
+// TopicManager implementation.
+//
+class TransientTopicManagerImpl : public TopicManagerInternal, public IceUtil::Mutex
+{
+public:
+
+    TransientTopicManagerImpl(const InstancePtr&);
+    ~TransientTopicManagerImpl();
+
+    // TopicManager methods.
+    virtual TopicPrx create(const std::string&, const Ice::Current&);
+    virtual TopicPrx retrieve(const std::string&, const Ice::Current&) const;
+    virtual TopicDict retrieveAll(const Ice::Current&) const;
+    virtual Ice::SliceChecksumDict getSliceChecksums(const Ice::Current&) const;
+    virtual IceStormElection::NodePrx getReplicaNode(const Ice::Current&) const;
+
+    void reap();
+
+    void shutdown();
+
+    Ice::ObjectPtr getServant() const;
+
+private:
+
+    const InstancePtr _instance;
+    std::map<std::string, TransientTopicImplPtr> _topics;
+};
+typedef IceUtil::Handle<TransientTopicManagerImpl> TransientTopicManagerImplPtr;
+
+} // End namespace IceStorm
+
+#endif