ProtoBufStream.hpp

Go to the documentation of this file.

 
#ifndef ERSKAFKA_PROTOBUFSTREAM_HPP 
#define ERSKAFKA_PROTOBUFSTREAM_HPP
 
#include <ers/OutputStream.hpp>
#include "erskafka/ERSPublisher.hpp"
 
#include <string>
#include <vector>
#include <memory>
 
namespace erskafka
{    
    
  class ProtoBufStream : public ers::OutputStream {
  public:
    explicit ProtoBufStream( const std::string & param);
    void write( const ers::Issue & issue ) override;
        
  private:  
    std::unique_ptr<dunedaq::erskafka::ERSPublisher> m_publisher;
    std::string m_session;
    std::string m_application;
  };
} //namespace erskafka
 
#endif  //ERSKAFKA_ERSSTREAM_HPP