Pu Zhibing
2025-06-19 a05b419384e148fc950c77553816a2d05144f4ae
ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttReceiverMessageHandler.java
@@ -25,7 +25,7 @@
   @Override
   public void handleMessage(Message<?> message) throws MessagingException {
      MessageHeaders headers = message.getHeaders();
      log.info("线程名称:{},收到消息,主题:{},消息:{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload());
      log.error("线程名称:{},收到消息,主题:{},消息:{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload());
      // log.info("收到消息主题:{}", headers.get("mqtt_receivedTopic").toString());
      // log.info("收到消息:{}", message.getPayload());
      String s = message.getPayload().toString();
@@ -36,9 +36,6 @@
      switch (ability){
         case "event_msa_alarm":
            warnMsgService.saveWarnMsgService(jsonObject);
            break;
         case "event_msa_pic":
            warnMsgService.saveWarnMsgPicService(jsonObject);
            break;
      }
   }