topicSub.hpp

Go to the documentation of this file.

 
#ifndef RAD_TOPIC_SUB_HPP
#define RAD_TOPIC_SUB_HPP
 
#include <rad/topicHandler.hpp>
 
#include <azmq/message.hpp>
#include <azmq/socket.hpp>
 
#include <boost/asio.hpp>
 
#include <array>
 
namespace rad {
 
class TopicSub {
   public:
    using TopicHandler_t = std::function<void(const std::string&, const void*, size_t)>;
    using TopicHandlerMap_t = std::unordered_map<std::string, TopicHandler_t>;
 
    TopicSub(boost::asio::io_context& ios, std::unique_ptr<TopicHandler>&& fallback);
    ~TopicSub();
 
    void Subscribe(const std::string& topic_name);
    void Subscribe(const std::string& topic_name, TopicHandler_t handler);
    void Unsubscribe(const std::string& topic_name);
 
    void Connect(const std::string& endpoint);
    void Disconnect(const std::string& endpoint);
    void Flush();
 
    TopicSub(const TopicSub&) = delete;
    TopicSub& operator=(const TopicSub&) = delete;
    // Enable moving
    TopicSub(TopicSub&& rhs) = default;
 
   private:
    void Register();
    void Callback(boost::system::error_code const& error_code, azmq::message& msg, size_t nbytes);
 
    azmq::sub_socket m_socket;
    std::unique_ptr<TopicHandler> m_fallback_handler;
    TopicHandlerMap_t m_handlers_map;
};
 
}  // namespace rad
 
#endif  // RAD_TOPIC_SUB_HPP