ddsReaderListener.hpp

Go to the documentation of this file.

#ifndef RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_READER_LISTENER_HPP
#define RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_READER_LISTENER_HPP
 
#include <rtctk/componentFramework/dds.hpp>
 
namespace rtctk::componentFramework {

class DdsReaderListener : public virtual DataReaderListener {
public:
    // Constructor
    DdsReaderListener();
 
    // Destructor
    ~DdsReaderListener() noexcept override = default;
 
    void on_requested_deadline_missed(DataReader* reader,
                                      const RequestedDeadlineMissedStatus& status) override;
 
    void on_requested_incompatible_qos(DataReader* reader,
                                       const RequestedIncompatibleQosStatus& status) override;
 
    void on_liveliness_changed(DataReader* reader, const LivelinessChangedStatus& status) override;
 
    void
    on_subscription_matched(DataReader* reader, const SubscriptionMatchedStatus& status) override;
 
    void on_sample_rejected(DataReader* reader, const SampleRejectedStatus& status) override;
 
    void on_sample_lost(DataReader* reader, const SampleLostStatus& status) override;
 
protected:
    log4cplus::Logger m_logger;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_DATAPATH_DDS_READER_LISTENER_HPP