blob: ae3434ead597bdc634322e47a54fb7c4aeaf9b2d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
// Copyright (C) 2017 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause
#ifndef CLIENTSUBSCRIPTION_H
#define CLIENTSUBSCRIPTION_H
#include "websocketiodevice.h"
#include <QtCore/QObject>
#include <QtMqtt/QMqttClient>
#include <QtWebSockets/QWebSocket>
class ClientSubscription : public QObject
{
Q_OBJECT
public:
ClientSubscription(QObject *parent = nullptr);
void setUrl(const QUrl &url); // ie ws://broker.hivemq.com:8000/mqtt
void setTopic(const QString &topic);
void setVersion(int v);
signals:
void messageReceived(QByteArray);
void errorOccured();
public slots:
void connectAndSubscribe();
void handleMessage(const QByteArray &msgContent);
private:
QMqttClient m_client;
QMqttSubscription *m_subscription;
QUrl m_url;
QString m_topic;
WebSocketIODevice m_device;
int m_version;
};
#endif // CLIENTSUBSCRIPTION_H
|
