smSubscriber.hpp

Go to the documentation of this file.

 
#ifndef RAD_SM_SUBSCRIBER_HPP
#define RAD_SM_SUBSCRIBER_HPP
 
#include <rad/mal/subscriber.hpp>
#include <rad/smAdapter.hpp>
 
namespace rad {
 
template <typename TOPIC_TYPE, typename EVENT_TYPE>
class SMSubscriber : public rad::cii::Subscriber<TOPIC_TYPE> {
   public:
    SMSubscriber(const elt::mal::Uri& uri, SMAdapter& sm,
                 const std::optional<elt::mal::Mal::Properties> mal_properties = {})
        : rad::cii::Subscriber<TOPIC_TYPE>(uri,
                                           std::bind(&SMSubscriber::Callback, this,
                                                     std::placeholders::_1, std::placeholders::_2),
                                           mal_properties),
          m_sm(sm) {
        RAD_TRACE(GetLogger());
    }
 
    void Callback(elt::mal::ps::Subscriber<TOPIC_TYPE>& subscriber,
                  const elt::mal::ps::DataEvent<TOPIC_TYPE>& event) {
        RAD_TRACE(GetLogger());
 
        if (event.hasValidData()) {
            LOG4CPLUS_DEBUG(GetLogger(), "Received topic, posting event to SM via ASIO.");
            m_sm.PostEvent(rad::UniqueEvent(new EVENT_TYPE(event.getData()->clone())));
        } else {
            LOG4CPLUS_WARN(GetLogger(), "Received invalid data!");
        }
    }
 
    SMSubscriber(const SMSubscriber&) = delete;
    SMSubscriber& operator=(const SMSubscriber&) = delete;
 
    // Enable moving ??
    // SMSubscriber(SMSubscriber&& rhs) = default;
 
   private:
    rad::SMAdapter& m_sm;
};
 
}  // namespace rad
 
#endif  // RAD_SM_SUBSCRIBER_HPP