File tree 3 files changed +18
-2
lines changed
3 files changed +18
-2
lines changed Original file line number Diff line number Diff line change 1564
1564
#ifndef MY_MQTT_ETH_INIT_DELAY
1565
1565
#define MY_MQTT_ETH_INIT_DELAY 1000
1566
1566
#endif
1567
+ /**
1568
+ * @def MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT
1569
+ * @brief Set a MQTT broker socket connection timeout time.
1570
+ *
1571
+ * This define is useful if you want to change default MQTT TCP/IP broker
1572
+ * connection timeout. By default, it is 1000ms.
1573
+ * Example: @code #define MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT 1000 @endcode
1574
+ *
1575
+ * @endcode
1576
+ */
1577
+ #ifndef MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT
1578
+ #define MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT 1000
1579
+ #endif
1580
+
1567
1581
/**
1568
1582
* @def MY_IP_ADDRESS
1569
1583
* @brief Static ip address of gateway. If not defined, DHCP will be used.
Original file line number Diff line number Diff line change @@ -159,7 +159,7 @@ bool reconnectMQTT(void)
159
159
160
160
return true ;
161
161
}
162
- delay (1000 );
162
+ delay (MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT );
163
163
GATEWAY_DEBUG (PSTR (" !GWT:RMQ:FAIL\n " ));
164
164
return false ;
165
165
}
@@ -247,7 +247,7 @@ bool gatewayTransportInit(void)
247
247
#else
248
248
_MQTT_client.setServer (MY_CONTROLLER_URL_ADDRESS, MY_PORT);
249
249
#endif /* End of MY_CONTROLLER_IP_ADDRESS */
250
-
250
+ _MQTT_ethClient. setConnectionTimeout (MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT);
251
251
_MQTT_client.setCallback (incomingMQTT);
252
252
253
253
#if defined(MY_GATEWAY_ESP8266) || defined(MY_GATEWAY_ESP32)
Original file line number Diff line number Diff line change @@ -258,6 +258,8 @@ MY_MQTT_PASSWORD LITERAL1
258
258
MY_MQTT_PUBLISH_TOPIC_PREFIX LITERAL1
259
259
MY_MQTT_SUBSCRIBE_TOPIC_PREFIX LITERAL1
260
260
MY_MQTT_USER LITERAL1
261
+ MY_MQTT_ETH_CLIENT_CONNECTION_TIMEOUT LITERAL1
262
+ MY_MQTT_ETH_INIT_DELAY LITERAL1
261
263
MY_W5100_SPI_EN LITERAL1
262
264
MY_WIFI_SSID LITERAL1
263
265
MY_WIFI_BSSID LITERAL1
You can’t perform that action at this time.
0 commit comments