dengsixing 2 년 전
부모
커밋
c8a1be5360
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      src/main/java/com/fdkankan/scene/listener/RabbitMqListener.java

+ 1 - 0
src/main/java/com/fdkankan/scene/listener/RabbitMqListener.java

@@ -50,6 +50,7 @@ public class RabbitMqListener {
             hashMap = JSON.parseObject(msg, HashMap.class);
         }catch (Exception e){
             log.error("消息结果错误");
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
             return;
         }
         int sceneProId = (int)hashMap.get("sceneProId");