qtmqtt.h

#ifndef QTMQTT_H
#define QTMQTT_H

#include <QSslConfiguration>
#include <QtMqtt/QMqttClient>
#include "abstractmqtt.h"

class QtMqtt : public AbstractMqtt
{
    Q_OBJECT
public:
    explicit QtMqtt(QObject *parent = nullptr);
    ~QtMqtt();

   void setBroker(const QString &broker);
   void setSslConfiguration(const QSslConfiguration &ssl);
   void setCleanSession(const bool clean);
   void setClientId(const QString &id);
   void setKeepAlive(const quint16 second);
   void setUsername(const QString &username);
   void setPassword(const QString &password);
   void setWillTopic(const QString &topic);
   void setWillQos(const quint8 qos);
   void setWillRetain(const bool retain);
   void setWillMessage(const QByteArray &msg);

   void connectToHost();
   void disconnectFromHost();
   void publish(const QString &topic, const quint8 qos, const QByteArray &payload, const bool retain);
   void subscribe(const QString &topic, const quint8 qos);
   void unsubscribe(const QString &topic);
   MqttStatus status();

public slots:

private:
    QMqttClient       *m_client;
    bool               m_sslEnable;
    QSslSocket        *m_sslSocket;
    QSslConfiguration *m_sslConfig;
};

#endif // QTMQTT_H