更新代码

src/main/java/vc/thinker/absctacts/mqtt/publish/MqttCommandPush.java

@@ -47,9 +47,9 @@ public class MqttCommandPush {
                 mqttClient.publish(topic, message);
             }
         } catch (MqttException e) {
-            if (Objects.equals((int)MqttException.REASON_CODE_CLIENT_EXCEPTION,e.getReasonCode())
-                    || Objects.equals((int)MqttException.REASON_CODE_CLIENT_ALREADY_DISCONNECTED,e.getReasonCode())
+            if (Objects.equals((int)MqttException.REASON_CODE_CLIENT_ALREADY_DISCONNECTED,e.getReasonCode())
                     || Objects.equals((int)MqttException.REASON_CODE_CLIENT_NOT_CONNECTED,e.getReasonCode())
+                    || Objects.equals((int)MqttException.REASON_CODE_CONNECTION_LOST,e.getReasonCode())
             ){
                 ArrayBlockingQueue<DataReportArrayQueue> queue = DataReportQueueUtil.getArrayBlockingQueue();
                 DataReportArrayQueue obj = new DataReportArrayQueue();

src/main/java/vc/thinker/mqtt/forwardthinker/ThinkerProdProtocolClient.java

@@ -6,9 +6,9 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.stereotype.Component;
 import vc.thinker.absctacts.mqtt.protocol.AbstractNotSubscriptionMqttProtocol;
+import vc.thinker.mqtt.config.ThinkerMqttConnectionProperties;
 import vc.thinker.mqtt.forwardthinker.dto.ThinkerReportDTO;
 import vc.thinker.mqtt.forwardthinker.enums.FoxGatewayTopicDefinition;
-import vc.thinker.mqtt.config.ThinkerMqttConnectionProperties;
 
 import java.util.List;