阶段提交：iotm ,iots

src/main/java/com/yunfeiyun/agmp/iots/core/mqtt/network/MqttSubscriber.java

@@ -54,7 +54,7 @@ public class MqttSubscriber implements MqttCallbackExtended {
     public void messageArrived(String topic, MqttMessage mqttMessage) {
         try {
             String msgContent = new String(mqttMessage.getPayload(), StandardCharsets.UTF_8);
-            log.debug("【上报数据：收到】收到mqtt消息：" + topic + ", " + msgContent);
+            log.info("【上报数据：收到】收到mqtt消息：" + topic + ", " + msgContent);
             JSONObject obj = JSON.parseObject(msgContent);
             Device device = mqttCore.getDevice();
             if (null == device) {

src/main/java/com/yunfeiyun/agmp/iots/task/MqttSubScheduler.java

@@ -19,7 +19,7 @@ public class MqttSubScheduler {
     @Scheduled(cron = "5 0/40 * * * ?")
     public void reSubscribe() {
         try {
-            mqttManager.reSubscribe();
+            //mqttManager.reSubscribe();
         } catch (Exception e) {
             log.error("【设备重新订阅】【订阅】【重连】定时任务执行失败", e);
         }