coolneng/muraqib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Retry MQTT connection indefinitely until it works

Browse Source
This commit is contained in:
coolneng
2025-11-27 13:17:30 +01:00
parent 8907700a8a
commit f1a8ec6ed0
1 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/wlan.cpp
View File

@@ -17,16 +17,25 @@ void connect_wlan(Config *config) {
delay(1000); delay(1000);
Serial.print("."); Serial.print(".");
} }
Serial.println("");
Serial.println("WiFi connected"); Serial.println("WiFi connected");
} }
void connect_mqtt(PubSubClient &client, Config *config) { void connect_mqtt(PubSubClient &client, Config *config) {
if (!client.connected()) bool connection;
client.setServer(config->mqtt_host, config->mqtt_port); client.setServer(config->mqtt_host, config->mqtt_port);
if (client.connect(config->device_id, config->mqtt_user,
config->mqtt_password)) { while (!client.connected()) {
Serial.println("MQTT connected"); connection = client.connect(config->device_id, config->mqtt_user,
client.subscribe(config->topic); config->mqtt_password);
if (connection) {
Serial.println("MQTT connected");
client.subscribe(config->topic);
} else {
Serial.println("MQTT failed to connect");
Serial.println(client.state());
delay(5000);
}
} }
} }