清淤BUG修改

aijinhui

2023-12-05 b420562862a0cd3899490e87cdd48cc075bc8544

 ard-work/src/main/java/com/ruoyi/utils/qymqtt/newM/MessageCallback.java

@@ -40,7 +40,7 @@

   @Override //消息发布者消息发布完成产生的回调
   public void deliveryComplete(IMqttDeliveryToken token) {
      System.out.println("deliveryComplete---------" + token.isComplete());
      log.info("deliveryComplete---------" + token.isComplete());
      int messageId = token.getMessageId();
      String[] topics = token.getTopics();
      String clientId = token.getClient().getClientId();
@@ -50,13 +50,13 @@
         topicStr = topicStr + topic + ",";
      }
      topicStr = topicStr.substring(0, topicStr.length() - 1);
      System.out.println("消息发布完成,messageId="+messageId+",topics="+topicStr+",clientId="+clientId);
      log.info("消息发布完成,messageId="+messageId+",topics="+topicStr+",clientId="+clientId);
   }

   @Override//消息订阅者收到消息后触发的回调
   public void messageArrived(String topic, MqttMessage message) throws Exception {
      try {
            System.out.println("【车辆锁主题】："+topic+"【车辆锁信息】："+new String(message.getPayload(), StandardCharsets.UTF_8));
         log.info("【车辆锁主题】："+topic+"【车辆锁信息】："+new String(message.getPayload(), StandardCharsets.UTF_8));
         //出来回调数据
         List<ArdSyCarLock> ardSyCarLocks = carLockService.data(new String(message.getPayload(), StandardCharsets.UTF_8));
         //根据topic查询RTUID