Add MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT to config

MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT is useful for adjusting default
MQTT TCP/IP connection timeout by library user.

Author: mobrembski

MyConfig.h

@@ -1562,6 +1562,18 @@
 #ifndef MY_MQTT_ETH_INIT_DELAY
 #define MY_MQTT_ETH_INIT_DELAY 1000
 #endif
+/**
+ * @def MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT
+ * @brief Set a MQTT broker socket connection timeout time.
+ *
+ * This define is useful if you want to change default MQTT TCP/IP broker
+ * connection timeout. By default, it is 1000ms.
+ * Example: @code #define MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT 1000 @endcode
+ */
+#ifndef MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT
+#define MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT 1000
+#endif
+
 /**
  * @def MY_IP_ADDRESS
  * @brief Static ip address of gateway. If not defined, DHCP will be used.
@@ -2335,6 +2347,7 @@
 #define MY_MQTT_CLIENT_CERT
 #define MY_MQTT_CLIENT_KEY
 #define MY_MQTT_ETH_INIT_DELAY
+#define MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT
 #define MY_SIGNAL_REPORT_ENABLED
 // general
 #define MY_WITH_LEDS_BLINKING_INVERSE

core/MyGatewayTransportMQTTClient.cpp

@@ -159,7 +159,7 @@ bool reconnectMQTT(void)
 
 		return true;
 	}
-	delay(1000);
+	delay(MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT);
 	GATEWAY_DEBUG(PSTR("!GWT:RMQ:FAIL\n"));
 	return false;
 }
@@ -247,7 +247,7 @@ bool gatewayTransportInit(void)
 #else
 	_MQTT_client.setServer(MY_CONTROLLER_URL_ADDRESS, MY_PORT);
 #endif /* End of MY_CONTROLLER_IP_ADDRESS */
-
+	_MQTT_ethClient.setConnectionTimeout(MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT);
 	_MQTT_client.setCallback(incomingMQTT);
 
 #if defined(MY_GATEWAY_ESP8266) || defined(MY_GATEWAY_ESP32)

keywords.txt

@@ -258,6 +258,8 @@ MY_MQTT_PASSWORD	LITERAL1
 MY_MQTT_PUBLISH_TOPIC_PREFIX	LITERAL1
 MY_MQTT_SUBSCRIBE_TOPIC_PREFIX	LITERAL1
 MY_MQTT_USER	LITERAL1
+MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT	LITERAL1
+MY_MQTT_ETH_INIT_DELAY	LITERAL1
 MY_W5100_SPI_EN	LITERAL1
 MY_WIFI_SSID	LITERAL1
 MY_WIFI_BSSID	LITERAL1