CaCO3 3 年之前
父節點
當前提交
08f90de683
共有 1 個文件被更改,包括 8 次插入2 次删除
  1. 8 2
      code/components/jomjol_mqtt/interface_mqtt.cpp

+ 8 - 2
code/components/jomjol_mqtt/interface_mqtt.cpp

@@ -173,11 +173,17 @@ bool MQTT_Init() {
             LogFile.WriteToFile(ESP_LOG_ERROR, "MQTT - Could not register event (ret=" + std::to_string(ret) + ")!");
             LogFile.WriteToFile(ESP_LOG_ERROR, "MQTT - Could not register event (ret=" + std::to_string(ret) + ")!");
             return false;
             return false;
         }
         }
+
         ret = esp_mqtt_client_start(client);
         ret = esp_mqtt_client_start(client);
         if (ret != ESP_OK)
         if (ret != ESP_OK)
         {
         {
-            LogFile.WriteToFile(ESP_LOG_ERROR, "MQTT - Could not start client (ret=" + std::to_string(ret) + ")!");
-            return false;
+            LogFile.WriteToFile(ESP_LOG_WARN, "MQTT - Could not start client (ret=" + std::to_string(ret) + "), retrying...");
+            ret = esp_mqtt_client_start(client);
+            if (ret != ESP_OK)
+            {
+                LogFile.WriteToFile(ESP_LOG_ERROR, "MQTT - Could not start client (ret=" + std::to_string(ret) + ")!");
+                return false;
+            }
         }
         }
     }
     }
     else
     else