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/socket.hpp>
#include <azmq/message.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& topicName);
    void Subscribe(const std::string& topicName, TopicHandler_t handler);
    void Unsubscribe(const std::string& topicName);

    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& errorCode, azmq::message& msg, size_t nbytes);

    azmq::sub_socket              mSocket;
    std::unique_ptr<TopicHandler> mFallbackHandler;
    TopicHandlerMap_t             mHandlersMap;
};

} // namespace rad

#endif