lp-data-alarm/MQTTAgent/MQTTAgent.h

#pragma once

#include "MWareInterface.h"
#include <qmqtt.h>
#include <QtCore/QVariant>
#include <QtCore/QObject>

//using MQTTCbFunc = std::function<void(const std::string, const std::string)>;
class MQTTAgent : public QObject
{
	Q_OBJECT
public:
    MQTTAgent();
    ~MQTTAgent();

signals:
    void sigEvent(const std::string topic, const std::string msg);

public slots:
    void onReceived(const QMQTT::Message& message);

public:
    bool Connect(tagSetup ts);
    bool Subscribe(std::list<std::string> lstTopic);
    void Publish(std::string,QVariant v);
    QStringList hvals(QString k);
};

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