brokerOutput.h

Go to the documentation of this file.

/*****************************************
 * This file is documented for Doxygen.
 * If you modify this file please update
 * the comments so that Doxygen will still
 * be able to work.
 ****************************************/
#ifndef BROKEROUTPUT_H
#define BROKEROUTPUT_H

#include <json.h>
#include <output.h>
#include <Producer.h>

#include <mutex>
#include <string>
#include <vector>
#include <memory>

#include "outputTopic.h"

namespace glass3 {

class brokerOutput : public glass3::output::output {
 public:
    brokerOutput();

    explicit brokerOutput(const std::shared_ptr<json::Object> &config);

    ~brokerOutput();

    bool setup(std::shared_ptr<const json::Object> config) override;

    void clear() override;

    void setStationFileName(const std::string &filename);

    const std::string getStationFileName();

    void logProducer(const std::string &message);

 protected:
    void sendOutput(const std::string &type, const std::string &id,
                    const std::string &message) override;

    void sendToOutputTopics(const std::string &message);

    void sendHeartbeat() override;

 private:
    std::vector<glass3::outputTopic*> m_vOutputTopics;

    hazdevbroker::Producer * m_StationRequestProducer;

    RdKafka::Topic * m_StationRequestTopic;

    std::string m_sStationFileName;

    std::mutex & getMutex();

    std::mutex m_Mutex;
};
}  // namespace glass3
#endif  // BROKEROUTPUT_H