Merge branch 'dev' of http://git.estsh.com/i3-IMPP/i3plus-core into dev

6 years ago · 717a1b381a
parent b60ed385ec 409ea33ea0
commit 717a1b381a
1 changed files with 4 additions and 1 deletions
--- 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
@ -116,7 +116,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();
            }