1 files changed, 73 insertions, 0 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DDS_TopicBase_Connector_T.h b/CIAO/connectors/dds4ccm/impl/ndds/DDS_TopicBase_Connector_T.h
new file mode 100644
index 00000000000..69af82224f6
--- /dev/null
+++ b/CIAO/connectors/dds4ccm/impl/ndds/DDS_TopicBase_Connector_T.h
@@ -0,0 +1,73 @@
+/**
+ * @author Marcel Smit <msmit@remedy.nl>
+ *
+ * $Id$
+ *
+ * Wrapper facade for NDDS.
+ */
+#ifndef DDS_TOPIC_BASE_CONNECTOR_H
+#define DDS_TOPIC_BASE_CONNECTOR_H
+
+#include "ace/Copy_Disabled.h"
+#include "dds4ccm/impl/ndds/DDS_Base_Connector_T.h"
+#include "dds4ccm/impl/ndds/TopicListener_T.h"
+#include "dds4ccm/impl/ndds/PublisherListener_T.h"
+#include "dds4ccm/impl/ndds/SubscriberListener_T.h"
+
+template <typename DDS_TYPE, typename CCM_TYPE>
+class DDS_TopicBase_Connector_T
+  : public virtual DDS_Base_Connector_T<DDS_TYPE, CCM_TYPE>
+{
+public:
+  DDS_TopicBase_Connector_T (void);
+  virtual ~DDS_TopicBase_Connector_T (void);
+
+  virtual char *topic_name (void);
+
+  virtual void topic_name (const char * topic_name);
+
+  virtual ::DDS::StringSeq *key_fields (void);
+
+  virtual void key_fields (const ::DDS::StringSeq & key_fields);
+
+  virtual void configuration_complete (void);
+  virtual void ccm_remove (void);
+  virtual void ccm_activate (ACE_Reactor* reactor);
+  virtual void ccm_passivate (void);
+
+protected:
+  void init_default_topic (void);
+  void init_publisher (void);
+  void init_subscriber (void);
+
+  void activate_default_topic (ACE_Reactor* reactor);
+  void activate_publisher (ACE_Reactor* reactor);
+  void activate_subscriber (ACE_Reactor* reactor);
+
+  void passivate_default_topic (void);
+  void passivate_publisher (void);
+  void passivate_subscriber (void);
+
+  void remove_default_topic (void);
+  void remove_publisher (void);
+  void remove_subscriber (void);
+
+  CORBA::String_var topic_name_;
+  DDS::StringSeq key_fields_;
+
+  ::DDS::Topic_var topic_;
+  ::DDS::TopicListener_var topiclistener_;
+
+  ::DDS::Publisher_var publisher_;
+  ::DDS::PublisherListener_var publisher_listener_;
+  ::DDS::Subscriber_var subscriber_;
+  ::DDS::SubscriberListener_var subscriber_listener_;
+
+typedef ::CIAO::DDS4CCM::TopicListener_T<DDS_TYPE, CCM_TYPE> TopicListener;
+typedef ::CIAO::DDS4CCM::SubscriberListener_T<DDS_TYPE, CCM_TYPE> SubscriberListener;
+typedef ::CIAO::DDS4CCM::PublisherListener_T<DDS_TYPE, CCM_TYPE> PublisherListener;
+};
+
+#include "dds4ccm/impl/ndds/DDS_TopicBase_Connector_T.cpp"
+
+#endif /* DDS_TOPIC_BASE_CONNECTOR_H */