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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright (C) 2017 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause
#include "clientsubscription.h"
#include <QtCore/QCoreApplication>
#include <QtCore/QCommandLineParser>
#include <QtCore/QLoggingCategory>
using namespace Qt::StringLiterals;
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
QCoreApplication::setApplicationVersion("1.0");
QCommandLineParser parser;
parser.setApplicationDescription(u"Websocket MQTT subscription tool"_s);
auto help = parser.addHelpOption();
// Use http://www.hivemq.com/demos/websocket-client/ in browser to publish
QCommandLineOption urlOption(QStringList{ u"host"_s, u"url"_s, u"broker"_s },
u"Host to connect to, eg ws://broker.hivemq.com:8000/mqtt"_s,
u"host"_s);
parser.addOption(urlOption);
QCommandLineOption subscriptionOption(QStringList{ u"t"_s, u"topic"_s },
u"Topic to subscribe to"_s, u"topic"_s);
parser.addOption(subscriptionOption);
QCommandLineOption debugOption(QStringList{ u"d"_s, u"debug"_s }, u"Enable Debug mode"_s);
parser.addOption(debugOption);
QCommandLineOption versionOption(QStringList{ u"v"_s, u"version"_s },
u"MQTT protocol version.\n3: MQTT 3.1\n4: MQTT 3.1.1"_s,
u"version"_s, u"3"_s);
parser.addOption(versionOption);
parser.process(a.arguments());
const QString debugLog = QString::fromLatin1("qtdemo.websocket.mqtt*=%1").arg(
parser.isSet(debugOption) ? "true" : "false");
QLoggingCategory::setFilterRules(debugLog);
ClientSubscription clientsub;
clientsub.setUrl(QUrl(parser.value(urlOption)));
clientsub.setTopic(parser.value(subscriptionOption));
const QString versionString = parser.value(versionOption);
if (versionString == "4") {
clientsub.setVersion(4);
} else if (versionString == "3") {
clientsub.setVersion(3);
} else {
qInfo() << "Unknown MQTT version";
return -2;
}
clientsub.connectAndSubscribe();
return a.exec();
}
|
