#ifndef Trans2mqtt_H
#define Trans2mqtt_H

#include "Trans2mqtt_global.h"
#include "Client.h"
#include "MQTTClient.h"
#include <QJsonObject>
class TRANS2MQTT_EXPORT Trans2Mqtt:public Client
{
public:
    Trans2Mqtt();
    ~Trans2Mqtt();
    virtual void Run(const ConsumerInfo& ci);
    virtual void OnData(const QString& user, const QString& key, const QVariant& val);
    virtual void setLoader(QLibrary*);
private:
    virtual void run();
    MQTTClient* mqtt = nullptr;
    std::list<std::string>dataItems;
    std::unordered_multimap<std::string, std::string>topicsMap;
    std::unordered_map<std::string, QJsonObject>dataMap;

};

extern "C" {//一定要添加上
TRANS2MQTT_EXPORT Client* instance();
TRANS2MQTT_EXPORT void destroy(Client*);
}

#endif // Trans2mqtt_H