ERSPublisher.hpp

Go to the documentation of this file.

 
#ifndef ERSKAFKA_INCLUDE_ERSKAFKA_ERSPUBLISHER_HPP_
#define ERSKAFKA_INCLUDE_ERSKAFKA_ERSPUBLISHER_HPP_
 
#include "nlohmann/json.hpp"
 
#include <librdkafka/rdkafkacpp.h>
 
#include <memory>
#include <string>
 
#include "ers/Schema.hpp"
 
namespace dunedaq {
 
namespace erskafka {
 
class ERSPublisher
{
 
public:
  ERSPublisher(const nlohmann::json& conf);
 
  ERSPublisher() = delete;
  ERSPublisher(const ERSPublisher&) = delete;
  ERSPublisher& operator=(const ERSPublisher&) = delete;
  ERSPublisher(ERSPublisher&&) = delete;
  ERSPublisher& operator=(ERSPublisher&&) = delete;
 
  ~ERSPublisher() { ; }
 
  bool publish(dunedaq::ersschema::IssueChain&&) const;
  // template<class Iterator>
  // bool publish( Iterator begin, Iterator end) const;
 
protected:
  std::string topic(const dunedaq::ersschema::IssueChain&) const { return m_default_topic; }
 
  std::string key(const dunedaq::ersschema::IssueChain& i) const { return i.session(); }
 
private:
  std::unique_ptr<RdKafka::Producer> m_producer;
  std::string m_default_topic = "monitoring.ers_stream";
};
} // erskafka namespace
} // dunedaq namespace
 
#endif // ERSKAFKA_INCLUDE_ERSKAFKA_ERSPUBLISHER_HPP_