msgParsers.hpp

Go to the documentation of this file.

#ifndef DEVMGR_COMMON_MSG_PARSERS_HPP_
#define DEVMGR_COMMON_MSG_PARSERS_HPP_

// Third party headers
#include <azmq/message.hpp>

// Local headers
#include <rad/MsgHandler.hpp>
#include <rad/TopicHandler.hpp>
#include <rad/Dispatcher.hpp>


namespace devmgr {
  namespace common {

    class MsgParsers  : public rad::MsgHandler {

    public:

      MsgParsers(rad::Dispatcher& event_dispatcher);

      virtual ~MsgParsers();

      void handle(const std::string& identity, const std::string& payload_type,
                  void const* msg, size_t msg_size);

      MsgParsers(const MsgParsers&) = delete;             
      MsgParsers& operator=(const MsgParsers&) = delete;  

    private:
      rad::Dispatcher& m_dispatcher;
    };

    class TopicParsers final : public rad::TopicHandler {

    public:
      TopicParsers(rad::Dispatcher& event_dispatcher);

      void handle(const std::string& payload_type, void const* topic,
                  size_t topic_size);

      TopicParsers(const TopicParsers&) = delete;     
      TopicParsers& operator=(const MsgParsers&) = delete;  

    private:
      rad::Dispatcher& m_dispatcher;    
    };

  } // namespace common
}  // namespace devmgr


#endif  // DEVMGR_COMMON_MSG_PARSERS_HPP_