Allow specifying custom port for MQTT connections

victronenergy · Oct 30, 2023 · 68a0d6d · 68a0d6d
1 parent 2066383
commit 68a0d6d
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/src/backendconnection.cpp b/src/backendconnection.cpp
@@ -195,7 +195,21 @@ void BackendConnection::initMqttConnection(const QString &address)
 #if defined(VENUS_WEBASSEMBLY_BUILD)
 	m_mqttProducer->open(QUrl(address), QMqttClient::MQTT_3_1);
 #else
-	m_mqttProducer->open(QHostAddress(address), 1883);
+	const QStringList parts = address.split(':');
+	if (parts.size() >= 2) {
+		bool ok = true;
+		const int port = parts[1].toInt(&ok);
+		if (ok) {
+			qDebug() << "connecting to: " << parts[0] << ":" << port;
+			m_mqttProducer->open(QHostAddress(parts[0]), port);
+		} else {
+			qWarning() << "Unable to parse port. Using default MQTT port: 1883";
+			m_mqttProducer->open(QHostAddress(parts[0]), 1883);
+		}
+	} else {
+		qDebug() << "Using default MQTT port: 1883";
+		m_mqttProducer->open(QHostAddress(address), 1883);
+	}
 #endif
 }