DataProducer.h

#ifndef _ots_DataProducer_h_
#define _ots_DataProducer_h_

#include "otsdaq/DataManager/DataProducerBase.h"
#include "otsdaq/WorkLoopManager/WorkLoop.h"

namespace ots
{
// DataProducer
//  This class provides base class functionality for Data Producer plugin classes to
//  receive incoming streaming data and places it in a Buffer.
class DataProducer : public DataProducerBase, public virtual WorkLoop
{
  public:
    DataProducer(std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, unsigned int bufferSize = 100);
    virtual ~DataProducer(void);

    virtual void startProcessingData(std::string runNumber);
    virtual void stopProcessingData(void);
};

}  // namespace ots

#endif