소스 검색

重复ack

lyhzzz 2 년 전
부모
커밋
b121d9a5d4
1개의 변경된 파일2개의 추가작업 그리고 1개의 파일을 삭제
  1. 2 1
      src/main/java/com/fdkankan/manage/mq/consumer/SceneRestStoreConsumer.java

+ 2 - 1
src/main/java/com/fdkankan/manage/mq/consumer/SceneRestStoreConsumer.java

@@ -48,7 +48,8 @@ public class SceneRestStoreConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.scene.rest-store:scene-rest-store}"),
-            concurrency = "1"
+            concurrency = "1",
+            ackMode = "MANUAL"
     )
     public void consumerQueue(Channel channel, Message message) throws IOException {
         try {