outputTopic.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 OUTPUTTOPIC_H
#define OUTPUTTOPIC_H

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

#include <string>

namespace glass3 {

class outputTopic {
 public:
    explicit outputTopic(hazdevbroker::Producer * producer);

    ~outputTopic();

    bool setup(const json::Value &config);

    void clear();

    bool isInBounds(double lat, double lon);

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

    void heartbeat();

 protected:
    double m_dTopLatitude;

    double m_dBottomLatitude;

    double m_dLeftLongitude;

    double m_dRightLongitude;

    std::string m_sTopicName;

 private:
    RdKafka::Topic * m_OutputTopic;

    hazdevbroker::Producer * m_OutputProducer;

    double m_dSendTime;

    int m_iRunningAverageCounter;

    double m_dRunningSendTimeAverage;

    int m_iMessageCounter;

    time_t tLastPerformanceReport;

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