msgParsers.hpp

Go to the documentation of this file.

#ifndef SERVER_MSG_PARSERS_HPP_
#define SERVER_MSG_PARSERS_HPP_

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

#include <azmq/message.hpp>

namespace server {

class MsgParsers final : 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) override;

    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) override;

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

 private:
    rad::Dispatcher& m_dispatcher;
};

}  // namespace server

#endif  // SERVER_MSG_PARSERS_HPP_