使用Spring integration DSL在我的errorChannel中出现任何错误时发送电子邮件
我正在使用DSL在spring集成中开发一个API，它是这样工作的。
JDBC Polling Adapter初始化流，并从表中获取一些数据并将其发送到DefaultRequestChannel，从这里消息通过不同的通道进行处理/流动。
现在我正试着
如果在我的错误通道中发生/检测到任何错误(例如，连接问题、轮询数据时发现错误记录)，
- 将发送电子邮件。
- 向我的支持小组发送电子邮件后，我想暂停我的流程15分钟，然后自动恢复。
我试着创建一个sendEmailChannel (我的errorChannel的接收者)，它对我不起作用。因此，我创建了一个如下所示的转换器方法
这段代码运行得很好，但这是一种好的做法吗？
@Transformer(inputChannel="errorChannel", outputChannel="suspendChannel")
public Message<?> errorChannelHandler(ErrorMessage errorMessage) throws RuntimeException, MessagingException, InterruptedException {
Exception exception = (Exception) errorMessage.getPayload();
String errorMsg = errorMessage.toString();
String subject = "API issue";
if (exception instanceof RuntimeException) {
errorMsg = "Run time exception";
subject = "Critical Alert";
}
if (exception instanceof JsonParseException) {
errorMsg = ....;
subject = .....;
}
MimeMessage message = sender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(message);
helper.setFrom(senderEmail);
helper.setTo(receiverEmail);
helper.setText(errorMsg);
helper.setSubject(subject);
sender.send(message);
kafkaProducerSwitch.isKafkaDown());
return MessageBuilder.withPayload(exception.getMessage())
.build();
}我正在寻找一些更好的方法来处理上述逻辑。还有任何建议，暂停我的流量几分钟。
回答 1
Stack Overflow用户
发布于 2019-06-03 06:40:54
您绝对可以使用Spring Integration box中的邮件发送通道适配器从错误通道https://docs.spring.io/spring-integration/docs/5.1.5.RELEASE/reference/html/#mail-outbound发送这些消息。Java DSL变体如下所示：
.handle(Mail.outboundAdapter("gmail")
.port(smtpServer.getPort())
.credentials("user", "pw")
.protocol("smtp")))当您检查某个AtimocBoolean bean的状态以激活beforeReceive()实现中的一个或另一个触发器时，可以通过CompoundTriggerAdvice扩展来完成挂起。这样AtimocBoolean可以在errorChannel的另一个订阅者中改变其状态，因为这个订阅者默认是PublishSubscribeChannel。在从beforeReceive()返回false之后，不要忘记将状态恢复到正常状态。仅仅因为这足以在此时将您的系统标记为正常，因为它将在15分钟后才能工作。
https://stackoverflow.com/questions/56412332
复制相似问题