From 984ec34d2f76bff59c997a46f3a09975166d89ce Mon Sep 17 00:00:00 2001
From: alwaysfrin <39822157+alwaysfrin@users.noreply.github.com>
Date: Tue, 12 Mar 2019 16:21:02 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E8=8B=A5=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E5=90=8E=E7=9A=84=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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();
             }