Added more MQTT "housekeeping"

fredlcore · Dec 6, 2024 · feb598a · feb598a
1 parent 0818afb
commit feb598a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/BSB_LAN/BSB_LAN.ino b/BSB_LAN/BSB_LAN.ino
@@ -3873,6 +3873,10 @@ void query(float line) {  // line (ProgNr)
       if (bus->getBusType() != BUS_PPS) {  // bus type is not PPS
         retry=QUERY_RETRIES;
         while (retry) {
+          if (mqtt_broker_addr[0] && (LoggingMode & CF_LOGMODE_MQTT)) { // Do MQTT housekeeping here in case delays occur...
+            mqtt_connect();        //Luposoft, connect to mqtt
+            MQTTPubSubClient->loop();    //Luposoft: listen to incoming messages
+          }
           if (bus->Send(query_type, c, msg, tx_msg) == BUS_OK) {
             // Decode the xmit telegram and send it to the PC serial interface
             if (verbose) {