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_service& 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