From 606a19ce7a7670585c6b6ec43fb75d68793877b1 Mon Sep 17 00:00:00 2001 From: Krzysztof Strehlau Date: Wed, 19 Jun 2024 15:50:08 +0200 Subject: [PATCH] Update ksMqttConnector.cpp --- src/ksf/comp/ksMqttConnector.cpp | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/src/ksf/comp/ksMqttConnector.cpp b/src/ksf/comp/ksMqttConnector.cpp index ee5d4dc..f214a41 100644 --- a/src/ksf/comp/ksMqttConnector.cpp +++ b/src/ksf/comp/ksMqttConnector.cpp @@ -107,6 +107,7 @@ namespace ksf::comps #if ESP32 netClientUq->setTimeout(KSF_MQTT_TIMEOUT_SEC); + netClientUq->setConnectionTimeout(KSF_SEC_TO_MS(KSF_MQTT_TIMEOUT_SEC)) #elif ESP8266 netClientUq->setTimeout(KSF_SEC_TO_MS(KSF_MQTT_TIMEOUT_SEC)); #else @@ -191,18 +192,10 @@ namespace ksf::comps out += PSTR("[MQTT] Connecting to MQTT broker..."); }); #endif - -#if ESP32 - if (IPAddress serverIP; serverIP.fromString(this->broker.c_str())) - netClientUq->connect(serverIP, portNumber, netClientUq->getTimeout()); - else - netClientUq->connect(this->broker.c_str(), portNumber, netClientUq->getTimeout()); -#else if (IPAddress serverIP; serverIP.fromString(this->broker.c_str())) netClientUq->connect(serverIP, portNumber); else netClientUq->connect(this->broker.c_str(), portNumber); -#endif /* If not connected, return. */ if (!netClientUq->connected())