Qt Quick Publication
// Copyright (C) 2018 The Qt Company Ltd. // SPDX-License-Identifier: LicenseRef-Qt-Commercial OR BSD-3-Clause import QtQuick import QtQuick.Window import QtQuick.Controls import QtQuick.Layouts Window { visible: true width: 640 height: 480 title: qsTr("Qt Quick Publication") id: root MqttClient { id: client hostname: hostnameField.text port: portField.text } ListModel { id: messageModel } function addMessage(payload) { messageModel.insert(0, {"payload" : payload}) if (messageModel.count >= 100) messageModel.remove(99) } GridLayout { anchors.fill: parent anchors.margins: 10 columns: 2 Label { text: "Hostname:" enabled: client.state === MqttClient.Disconnected } TextField { id: hostnameField Layout.fillWidth: true text: "test.mosquitto.org" placeholderText: "<Enter host running MQTT broker>" enabled: client.state === MqttClient.Disconnected } Label { text: "Port:" enabled: client.state === MqttClient.Disconnected } TextField { id: portField Layout.fillWidth: true text: "1883" placeholderText: "<Port>" inputMethodHints: Qt.ImhDigitsOnly enabled: client.state === MqttClient.Disconnected } Button { id: connectButton Layout.columnSpan: 2 Layout.fillWidth: true text: client.state === MqttClient.Connected ? "Disconnect" : "Connect" onClicked: { if (client.state === MqttClient.Connected) { client.disconnectFromHost() messageModel.clear() } else client.connectToHost() } } GridLayout { enabled: client.state === MqttClient.Connected Layout.columnSpan: 2 Layout.fillWidth: true columns: 4 Label { text: "Topic:" } TextField { id: pubField Layout.fillWidth: true placeholderText: "<Publication topic>" } Label { text: "Message:" } TextField { id: msgField Layout.fillWidth: true placeholderText: "<Publication message>" } Label { text: "QoS:" } ComboBox { id: qosItems Layout.fillWidth: true editable: false model: [0, 1, 2] } CheckBox { id: retain checked: false text: "Retain" } Button { id: pubButton Layout.fillWidth: true text: "Publish" onClicked: { if (pubField.text.length === 0) { console.log("No payload to send. Skipping publish...") return } client.publish(pubField.text, msgField.text, qosItems.currentText, retain.checked) root.addMessage(msgField.text) } } } ListView { id: messageView model: messageModel implicitHeight: 300 implicitWidth: 200 Layout.fillHeight: true Layout.fillWidth: true Layout.columnSpan: 2 clip: true delegate: Rectangle { id: delegatedRectangle required property int index required property string payload width: ListView.view.width height: 30 color: index % 2 ? "#DDDDDD" : "#888888" radius: 5 Text { text: delegatedRectangle.payload anchors.centerIn: parent } } } Label { function stateToString(value) { if (value === 0) return "Disconnected" else if (value === 1) return "Connecting" else if (value === 2) return "Connected" else return "Unknown" } Layout.columnSpan: 2 Layout.fillWidth: true color: "#333333" text: "Status:" + stateToString(client.state) + "(" + client.state + ")" enabled: client.state === MqttClient.Connected } } }