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