diff --git a/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java b/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java index ab31cb5..21886f2 100644 --- a/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java +++ b/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java @@ -1,7 +1,10 @@ package com.xwbing.rabbit; +import com.xwbing.exception.BusinessException; import com.xwbing.service.rest.MailService; import com.xwbing.util.RestMessage; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @@ -21,6 +24,7 @@ import static com.xwbing.rabbit.RabbitConstant.MESSAGE_QUEUE; public class Receiver { @Resource private MailService mailService; + private final Logger logger = LoggerFactory.getLogger(Receiver.class); /** * 处理邮件队列信息 @@ -31,7 +35,12 @@ public class Receiver { @RabbitListener(queues = EMAIL_QUEUE) public String processEmail(String[] msg) { String content = MessageFormat.format("你的用户名是:{0},密码是:{1}", msg[1], msg[2]); - RestMessage restMessage = mailService.sendSimpleMail(msg[0], "注册成功", content); + RestMessage restMessage = new RestMessage(); + try { + restMessage = mailService.sendSimpleMail(msg[0], "注册成功", content); + } catch (BusinessException e) { + logger.error("发送邮件给{}失败", msg[0]); + } boolean success = restMessage.isSuccess(); return MessageFormat.format("成功发送邮件给{0}:{1}", msg[1], success); }