1 #ifndef _ots_TCPDataListenerProducer_h_
2 #define _ots_TCPDataListenerProducer_h_
4 #include "otsdaq/Configurable/Configurable.h"
5 #include "otsdaq/DataManager/DataProducer.h"
6 #include "otsdaq/NetworkUtilities/TCPSubscribeClient.h"
12 class ConfigurationTree;
18 std::string bufferUID,
19 std::string processorUID,
21 const std::string& configurationPath);
23 virtual void startProcessingData(std::string runNumber)
override;
24 virtual void stopProcessingData(
void)
override;
27 bool workLoopThread(toolbox::task::WorkLoop* workLoop)
override;
32 std::map<std::string, std::string> header_;
35 std::map<std::string, std::string>* headerP_;
37 std::string ipAddress_;
39 std::string dataType_;