summaryrefslogtreecommitdiff
path: root/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h
diff options
context:
space:
mode:
Diffstat (limited to 'CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h')
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h105
1 files changed, 51 insertions, 54 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h b/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h
index afac9aaf915..aecff4d659d 100644
--- a/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h
+++ b/CIAO/connectors/dds4ccm/impl/ndds/SubscriberListener.h
@@ -35,61 +35,58 @@ namespace CIAO
{
namespace DDS4CCM
{
- namespace RTI
+ class DDS4CCM_NDDS_IMPL_Export CCM_DDS_SubscriberListener_i :
+ public virtual ::DDSSubscriberListener
{
- class DDS4CCM_NDDS_IMPL_Export RTI_SubscriberListener_i :
- public virtual ::DDSSubscriberListener
- {
- public:
- // Constructor
- RTI_SubscriberListener_i ( ::DDS::SubscriberListener_ptr s);
-
- // Destructor
- virtual ~RTI_SubscriberListener_i (void);
-
- virtual void
- on_requested_deadline_missed (
- ::DDSDataReader* the_reader,
- const ::DDS_RequestedDeadlineMissedStatus & status);
-
- virtual void
- on_requested_incompatible_qos (
- ::DDSDataReader* the_reader,
- const ::DDS_RequestedIncompatibleQosStatus & status);
-
- virtual void
- on_sample_rejected (
- ::DDSDataReader* the_reader,
- const ::DDS_SampleRejectedStatus & status);
-
- virtual void
- on_liveliness_changed (
- ::DDSDataReader* the_reader,
- const ::DDS_LivelinessChangedStatus & status);
-
- virtual void
- on_data_available (
- ::DDSDataReader* the_reader);
-
- virtual void
- on_subscription_matched (
- ::DDSDataReader* the_reader,
- const ::DDS_SubscriptionMatchedStatus & status);
-
- virtual void
- on_sample_lost (
- ::DDSDataReader* the_reader,
- const ::DDS_SampleLostStatus & status);
-
- virtual void
- on_data_on_readers (
- ::DDSSubscriber* the_subscriber);
-
- ::DDS::SubscriberListener_ptr get_subscriber_listener (void);
- private:
- ::DDS::SubscriberListener_var impl_;
- };
- }
+ public:
+ /// Constructor
+ CCM_DDS_SubscriberListener_i ( ::DDS::SubscriberListener_ptr s);
+
+ /// Destructor
+ virtual ~CCM_DDS_SubscriberListener_i (void);
+
+ virtual void
+ on_requested_deadline_missed (
+ ::DDSDataReader* the_reader,
+ const ::DDS_RequestedDeadlineMissedStatus & status);
+
+ virtual void
+ on_requested_incompatible_qos (
+ ::DDSDataReader* the_reader,
+ const ::DDS_RequestedIncompatibleQosStatus & status);
+
+ virtual void
+ on_sample_rejected (
+ ::DDSDataReader* the_reader,
+ const ::DDS_SampleRejectedStatus & status);
+
+ virtual void
+ on_liveliness_changed (
+ ::DDSDataReader* the_reader,
+ const ::DDS_LivelinessChangedStatus & status);
+
+ virtual void
+ on_data_available (
+ ::DDSDataReader* the_reader);
+
+ virtual void
+ on_subscription_matched (
+ ::DDSDataReader* the_reader,
+ const ::DDS_SubscriptionMatchedStatus & status);
+
+ virtual void
+ on_sample_lost (
+ ::DDSDataReader* the_reader,
+ const ::DDS_SampleLostStatus & status);
+
+ virtual void
+ on_data_on_readers (
+ ::DDSSubscriber* the_subscriber);
+
+ ::DDS::SubscriberListener_ptr get_subscriber_listener (void);
+ private:
+ ::DDS::SubscriberListener_var impl_;
+ };
}
}