TopicPub.hpp

Go to the documentation of this file.

#ifndef RAD_TOPIC_PUB_HPP
#define RAD_TOPIC_PUB_HPP

#include <rad/Logger.hpp>

#include <azmq/socket.hpp>
#include <azmq/message.hpp>

#include <boost/asio.hpp>


namespace rad {

class TopicPub {

public:
    TopicPub(boost::asio::io_service& ios, const std::string& endpoint);
    virtual ~TopicPub();

    size_t PublishRaw(const std::string& topic, const std::string& buffer);

    template<typename TYPE>
    size_t Publish(const std::string& topic, const TYPE& buffer);

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

private:
    azmq::pub_socket mSocket;
};

template<typename TYPE>
size_t TopicPub::Publish(const std::string& topic, const TYPE& buffer)
{
    RAD_LOG_TRACE();

    std::string serializedBuffer;
    if (buffer.SerializeToString(&serializedBuffer) == false) {
        RAD_LOG_ERROR() << "serializing topic " << topic;
        return 0;
    }
    return PublishRaw(topic, serializedBuffer);
}


} // namespace rad

#endif