时间戳

首页 > 解决方案 > 使用 Spring 集成 DSL 在我的 errorChannel 中出现任何错误时发送电子邮件

spring-integration - 使用 Spring 集成 DSL 在我的 errorChannel 中出现任何错误时发送电子邮件

问题描述

我正在使用 DSL 在 spring-integration 中开发一个 API，它是这样工作的

JDBC 轮询适配器启动流程并从表中获取一些数据并将其发送到 DefaultRequestChannel，从这里消息通过各种通道进行处理/流动。

现在我正在尝试
1. 发送一封电子邮件，如果在我的错误通道中发生/检测到任何错误（例如连接问题、轮询数据时发现的错误记录）。

  1. 向我的支持小组发送电子邮件后，我想暂停我的流程 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();
}

我正在寻找一些更好的方法来处理上述逻辑。还有任何建议暂停我的流程几分钟。

标签： spring-integrationspring-integration-dsl

解决方案

您绝对可以使用 Spring Integration 框中的邮件发送通道适配器从错误通道发送这些消息：https ://docs.spring.io/spring-integration/docs/5.1.5.RELEASE/reference/html/#mail -出境。Java DSL 变体是这样的：

.handle(Mail.outboundAdapter("gmail")
                        .port(smtpServer.getPort())
                        .credentials("user", "pw")
                        .protocol("smtp")))

CompoundTriggerAdvice当您检查某个AtimocBooleanbean 的状态以激活实现中的一个或另一个触发器时，可以通过扩展来完成挂起beforeReceive()。这样的 aAtimocBoolean可以在另外一个订阅者中将其状态更改为 that，errorChannel因为默认情况下这是 a PublishSubscribeChannel。在您false从beforeReceive(). 仅仅因为这足以在此时将您的系统标记为正常，因为它只会在 15 分钟后工作。

推荐阅读