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/smAdapter.hpp>
#include <rad/topicHandler.hpp>

#include <azmq/message.hpp>

namespace server {

class MsgParsers final : public rad::MsgHandler {
   public:
    explicit MsgParsers(rad::SMAdapter& sm);
    virtual ~MsgParsers();

    void Handle(const std::string& identity, const std::string& payload_type, void const* msg,
                size_t sz) override;

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

   private:
    rad::SMAdapter& m_sm;
};

class TopicParsers final : public rad::TopicHandler {
   public:
    explicit TopicParsers(rad::SMAdapter& sm);

    void Handle(const std::string& payload_type, void const* topic, size_t sz) override;

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

   private:
    rad::SMAdapter& m_sm;
};

}  // namespace server

#endif  // SERVER_MSG_PARSERS_HPP_