iarv/Meck
1
0
Fork 1
mirror of https://github.com/pelgraine/Meck.git synced 2026-05-02 03:22:38 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix mqttsubscribe

Browse Source
This commit is contained in:
pelgraine
2026-03-30 13:11:54 +11:00
parent 0cab2ddfa7
commit 9ddb692806
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
examples/simple_repeater/cellularmqtt.cpp
View File

@@ -792,8 +792,20 @@ restart:
goto restart;
}
mqttSubscribe(_topicCmd);
mqttSubscribe(_topicOta);
// Allow MQTT session to stabilise before subscribing
vTaskDelay(pdMS_TO_TICKS(2000));
// Subscribe with retry — the modem sometimes misses the first prompt
for (int i = 0; i < 3; i++) {
if (mqttSubscribe(_topicCmd)) break;
Serial.printf("[Cell] Subscribe retry %d for cmd topic\n", i + 1);
vTaskDelay(pdMS_TO_TICKS(1000));
}
for (int i = 0; i < 3; i++) {
if (mqttSubscribe(_topicOta)) break;
Serial.printf("[Cell] Subscribe retry %d for ota topic\n", i + 1);
vTaskDelay(pdMS_TO_TICKS(1000));
}
_state = CellState::CONNECTED;
_reconnectDelay = MQTT_RECONNECT_MIN;