浏览代码

fix: 修复mq消费ack异常

Marko552 4 年之前
父节点
当前提交
6b7f328b66

+ 2 - 5
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/infrastructure/mq/TableStoreBatchInsertConsumer.java

@@ -33,16 +33,13 @@ public class TableStoreBatchInsertConsumer implements ChannelAwareMessageListene
 
     @Override
     @SneakyThrows
-    @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE)
+    @RabbitListener(queues = TABLE_STORE_BATCH_INSERT_QUEUE,ackMode="auto")
     public void onMessage(Message message, Channel channel){
-        long deliveryTag = message.getMessageProperties().getDeliveryTag();
         try {
             String messageInfo = new String(message.getBody(), "utf-8");
             operateTableStore(messageInfo);
-            channel.basicAck(deliveryTag, false);
         } catch (Exception e) {
-            log.error("DEMO异常:{}", e);
-            channel.basicAck(deliveryTag, false);
+            log.error("保存码到TableStore异常:{}", e);
         }
     }