捕获春季集成DSL错误配置异常



使用DSL时是否有一种方法可以捕获DestinationResolutionExceptionMessageDispatchingException?这些例外通常表示配置错误,但我不确定如何配置我的流程以捕获这些异常并应用一些自定义逻辑?

@SpringBootApplication
public class IntegrationMisconfigurationExampleApplication {
  public static void main(final String[] args) {
    SpringApplication.run(IntegrationMisconfigurationExampleApplication.class, args);
  }
  @Bean
  public IntegrationFlow loggingFlow() {
    return IntegrationFlows.from("input")
        .<String, String>transform(String::toUpperCase)
        // .nullChannel();
        .get();
  }
  @Bean
  public CommandLineRunner demo() {
    return args -> {
      final MessagingTemplate template = messagingTemplate();
      template.convertAndSend("input", "abc");
    };
  }
  @Bean
  public MessagingTemplate messagingTemplate() {
    return new MessagingTemplate();
  }
}

上面的示例引发了DestinationResolutionException,因为loggingFlow.transformer#0未正确初始化。有没有办法抓住这个例外?

这些异常是运行时错误。我们真的无法确定启动时的配置错误。

捕获这样的运行时异常并进行一些分析工作的方法是使用ExpressionEvaluatingRequestHandlerAdvice,您可以在第二个参数中添加到transform(String::toUpperCase)配置中以进行端点配置:

.<String, String>transform(String::toUpperCase, e-> e.advice(myExpressionEvaluatingRequestHandlerAdvice()))

在参考手册中查看有关此建议的更多信息:https://docs.spring.io/spring-integration/docs/current/referent/referent/html/#message handler-advice-chain

您还需要记住,transformer确实是 request-reply-reply 组件,具有所需的非零返回值。因此,您真的不能仅仅为单向流程配置transform()。当流程中没有下一个通道或消息中没有replyChannel标题时,它将引发异常。

相关内容

  • 没有找到相关文章

最新更新