topicHandler.hpp

Go to the documentation of this file.

 
#ifndef RAD_TOPIC_HANDLER_HPP
#define RAD_TOPIC_HANDLER_HPP
 
#include <rad/exceptions.hpp>
 
#include <memory>
#include <string>
#include <unordered_map>
 
namespace rad {
 
class TopicHandler {
   public:
    virtual ~TopicHandler() {}
    virtual void Handle(const std::string& topic_type_id, const void* data, size_t data_size) = 0;
};
 
template <typename EventType>
EventType ParseTopicAndCreateEvent(const std::string& topic_name, const void* msg,
                                   size_t msg_size) {
    typename EventType::payload_t topic_payload;
    if (topic_payload.ParseFromArray(msg, msg_size) == false) {
        throw rad::Exception("Error parsing <" + topic_name + "> payload.");
    }
    return EventType(topic_payload);
}
 
}  // namespace rad
 
#endif /* #ifndef RAD_TOPIC_HANDLER_HPP */