examples/InteractiveStreamingExample/MonitoringProcessor.h

0001
0002 // Copyright 2020, Jefferson Science Associates, LLC.
0003 // Subject to the terms in the LICENSE file found in the top-level directory.
0004
0005 #ifndef _MonitoringProcessor_h_
0006 #define _MonitoringProcessor_h_
0007
0008 #include <mutex>
0009
0010 #include <JANA/JEventProcessor.h>
0011 #include "ZmqTransport.h"
0012 #include "INDRAMessage.h"
0013
0014 class MonitoringProcessor : public JEventProcessor {
0015
0016 public:
0017
0018     MonitoringProcessor();
0019     virtual ~MonitoringProcessor();
0020
0021     virtual void Init(void);
0022     virtual void Process(const std::shared_ptr<const JEvent> &aEvent);
0023     virtual void Finish(void);
0024
0025 private:
0026
0027     std::mutex msgMutex;
0028     std::string m_pub_socket;
0029     ZmqTransport *m_transport  = nullptr;
0030     DASEventMessage *m_message = nullptr;
0031 };
0032
0033 #endif // _MonitoringProcessor_h_
0034