brokerInput.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 BROKERINPUT_H
#define BROKERINPUT_H

#include <json.h>
#include <threadbaseclass.h>
#include <input.h>
#include <Consumer.h>

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

namespace glass3 {

class brokerInput : public glass3::input::Input {
 public:
    brokerInput();

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

    ~brokerInput();

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

    void clear() override;

 protected:
    std::string fetchRawData(std::string* pOutType) override;

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

 private:
    hazdevbroker::Consumer * m_Consumer;

    int m_iBrokerHeartbeatInterval;

    double m_dPollTime;

    int m_iRunningAverageCounter;

    double m_dRunningPollTimeAverage;

    int m_iMessageCounter;

    time_t tLastPerformanceReport;

    int m_iReportInterval;
};
}  // namespace glass3
#endif  // BROKERINPUT_H