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_