消息若发送失败后的处理

yun-zuoyi
alwaysfrin 6 years ago
parent 9f20dd7665
commit 984ec34d2f

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

Loading…
Cancel
Save