1 files changed, 120 insertions, 0 deletions
diff --git a/modules/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.cpp b/modules/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.cpp
new file mode 100644
index 00000000000..1a894786c21
--- /dev/null
+++ b/modules/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.cpp
@@ -0,0 +1,120 @@
+// $Id$
+
+#include "SubscriberListener.h"
+#include "Subscriber.h"
+#include "DataReader.h"
+#include "SampleLostStatus.h"
+#include "SubscriptionMatchedStatus.h"
+#include "RequestedDeadlineMissedStatus.h"
+#include "SampleRejectedStatus.h"
+#include "LivelinessChangedStatus.h"
+#include "RequestedIncompatibleQosStatus.h"
+
+namespace CIAO
+{
+  namespace DDS4CCM
+  {
+    namespace RTI
+    {
+      // Implementation skeleton constructor
+      RTI_SubscriberListener_i::RTI_SubscriberListener_i (::DDS::SubscriberListener_ptr p)
+        : impl_ ( ::DDS::SubscriberListener::_duplicate (p))
+      {
+      }
+
+      // Implementation skeleton destructor
+      RTI_SubscriberListener_i::~RTI_SubscriberListener_i (void)
+      {
+      }
+
+      void
+      RTI_SubscriberListener_i::on_data_on_readers (
+          ::DDSSubscriber* the_subscriber)
+      {
+        ::DDS::Subscriber_var sub = new RTI_Subscriber_i (the_subscriber);
+        this->impl_->on_data_on_readers (sub.in ());
+      }
+
+      void
+      RTI_SubscriberListener_i::on_requested_deadline_missed (
+        ::DDSDataReader* the_reader,
+        const ::DDS_RequestedDeadlineMissedStatus & status)
+      {
+        ::DDS::RequestedDeadlineMissedStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_requested_deadline_missed (dds_reader.in (), ddsstatus);
+      }
+
+      void
+      RTI_SubscriberListener_i::on_requested_incompatible_qos (
+        ::DDSDataReader* the_reader,
+        const ::DDS_RequestedIncompatibleQosStatus & status)
+      {
+        ::DDS::RequestedIncompatibleQosStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_requested_incompatible_qos (dds_reader.in (), ddsstatus);
+      }
+
+      void
+      RTI_SubscriberListener_i::on_sample_rejected (
+        ::DDSDataReader* the_reader,
+        const ::DDS_SampleRejectedStatus & status)
+      {
+        ::DDS::SampleRejectedStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_sample_rejected (dds_reader.in (), ddsstatus);
+      }
+
+      void
+      RTI_SubscriberListener_i::on_liveliness_changed (
+        ::DDSDataReader* the_reader,
+        const ::DDS_LivelinessChangedStatus & status)
+      {
+        ::DDS::LivelinessChangedStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_liveliness_changed (dds_reader.in (), ddsstatus);
+      }
+
+      void
+      RTI_SubscriberListener_i::on_data_available (
+        ::DDSDataReader* the_reader)
+      {
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_data_available (dds_reader.in ());
+      }
+
+      void
+      RTI_SubscriberListener_i::on_subscription_matched (
+        ::DDSDataReader* the_reader,
+        const ::DDS_SubscriptionMatchedStatus & status)
+      {
+        ::DDS::SubscriptionMatchedStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_subscription_matched (dds_reader.in (), ddsstatus);
+      }
+
+      void
+      RTI_SubscriberListener_i::on_sample_lost (
+        ::DDSDataReader* the_reader,
+        const ::DDS_SampleLostStatus & status)
+      {
+        ::DDS::SampleLostStatus ddsstatus;
+        ddsstatus <<= status;
+        ::DDS::DataReader_var dds_reader = new RTI_DataReader_i (the_reader);
+        this->impl_->on_sample_lost (dds_reader.in (), ddsstatus);
+      }
+
+      ::DDS::SubscriberListener_ptr
+      RTI_SubscriberListener_i::get_subscriber_listener (void)
+      {
+        return ::DDS::SubscriberListener::_duplicate (this->impl_.in ());
+      }
+    }
+  }
+}
+