Sternenlabor/nuki_hub
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix mqtt reconnect

Browse Source
This commit is contained in:
technyon
2023-01-28 12:18:20 +01:00
parent 9d9f387710
commit 88c3b656be
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
Network.cpp
View File

@@ -240,24 +240,32 @@ bool Network::reconnect()
while (!_device->mqttClient()->connected() && millis() > _nextReconnect) while (!_device->mqttClient()->connected() && millis() > _nextReconnect)
{ {
if(strcmp(_mqttBrokerAddr, "") == 0)
{
Log->println(F("MQTT Broker not configured, aborting connection attempt."));
_nextReconnect = millis() + 5000;
return false;
}
Log->println(F("Attempting MQTT connection")); Log->println(F("Attempting MQTT connection"));
bool success = false;
if(strlen(_mqttUser) == 0) if(strlen(_mqttUser) == 0)
{ {
Log->println(F("MQTT: Connecting without credentials")); Log->println(F("MQTT: Connecting without credentials"));
_device->mqttClient()->setServer(_mqttBrokerAddr, port); _device->mqttClient()->setServer(_mqttBrokerAddr, port);
success = _device->mqttClient()->connect(); _device->mqttClient()->connect();
} }
else else
{ {
Log->print(F("MQTT: Connecting with user: ")); Log->println(_mqttUser); Log->print(F("MQTT: Connecting with user: ")); Log->println(_mqttUser);
_device->mqttClient()->setCredentials(_mqttUser, _mqttPass); _device->mqttClient()->setCredentials(_mqttUser, _mqttPass);
_device->mqttClient()->setServer(_mqttBrokerAddr, port); _device->mqttClient()->setServer(_mqttBrokerAddr, port);
success = _device->mqttClient()->connect(); _device->mqttClient()->connect();
} }
if (success) delay(200);
if (_device->mqttClient()->connected())
{ {
Log->println(F("MQTT connected")); Log->println(F("MQTT connected"));
_mqttConnectionState = 1; _mqttConnectionState = 1;