ddsReaderListener.hpp

Go to the documentation of this file.

#ifndef RTCKT_TELSUB_DDS_READER_LISTENER_HPP
#define RTCKT_TELSUB_DDS_READER_LISTENER_HPP
 
#include <rtctk/componentFramework/dds.hpp>
#include <rtctk/componentFramework/logger.hpp>
 
namespace rtctk::telSub {
 
using namespace rtctk::componentFramework;

class DdsReaderListener : public virtual DataReaderListener {
    log4cplus::Logger& m_logger;
 
public:
    // Constructor
    DdsReaderListener();
 
    // Destructor
    ~DdsReaderListener() 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;
};
 
}  // namespace rtctk::telSub
 
#endif  // RTCKT_TELSUB_DDS_READER_LISTENER_HPP