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/message.hpp>
#include <azmq/socket.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 m_socket;
};

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

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

}  // namespace rad

#endif  // RAD_TOPIC_PUB_HPP