Update ksMqttConnector.cpp

cziter15 · Jun 19, 2024 · 606a19c · 606a19c
1 parent 805c1dc
commit 606a19c
Showing 1 changed file with 1 addition and 8 deletions.
diff --git 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())