diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java index 3c3197d..dfda033 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java @@ -113,7 +113,10 @@ public class MessageMailQueueReceiver { //丢弃这条消息 try { // 未成功处理,重新发送 - channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true); + //channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true); + //todo 此处对邮件持久化,通过参数设置,是否还需要重复重新发送 + // 改为接收成功 + channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); } catch (IOException e1) { e1.printStackTrace(); }