使用建议处理MessageHandlingException并继续spring集成dsl的流程

Question

我试图抑制从http出站网关为非2XX状态代码生成的MessageHandlingException，并将控制优雅地返回到父流，以便按照成功流中的预期在回复通道上返回具有原始有效负载的消息。

原始代码：

 @Bean
  public IntegrationFlow inquiry() {
    return flow -> flow
    .handle(Http
                .outboundGateway("url", restTemplate)
                .mappedRequestHeaders("*")
                .headerMapper(headerMapper)
                .extractPayload(true)
                .httpMethod(HttpMethod.POST)
                .expectedResponseType(expectedResponseType.class)
            )

我尝试在Http上使用errorHandler，但它为客户端响应提供了一个句柄，并且原始负载不是它的一部分。

也尝试了表达建议的途径。

@Bean
  public IntegrationFlow inquiry() {
    return flow -> flow
    .handle(Http
                    .outboundGateway("url", restTemplate)
                    .mappedRequestHeaders("*")
                    .headerMapper(headerMapper)
                    .extractPayload(true)
                    .httpMethod(HttpMethod.POST)
                    .expectedResponseType(expectedResponseType.class)
                , c->c.advice(expresionAdvice())) 

如果没有成功，则通知不会返回控件

也许最简单的方法就是把纸包起来。处理try。。捕获并捕获MessageHandlingException，将其传播到@ExceptionHandler并对其进行转换。

有没有一种方法可以通过advice或errorChannel来实现，在@MessagingGateway上尝试了errorChannel，但在http出站网关发出404后，它不会被调用。

上面的代码是另一个流的一部分，正在独立测试这个流。

integrationFlow是否存在错误通道？

更新1：

能够找出为什么@MessagingGateway上的错误通道没有从测试中调用，它只在调用完整流时才被调用，而不是使用DirectChannel的查询（）方法。

现在errorChannel正在工作，请使用异常之前的有效负载状态设置一个自定义头，并从failedMessage头访问它。

它现在正按预期工作，并且从不将错误抛回响应。感觉这是一个工作...

有什么方法可以在建议中更好地处理这个问题吗？

编辑1：

代码不完整，我试图让它工作

@Bean
  public Advice expressionAdvice() {
    ExpressionEvaluatingRequestHandlerAdvice advice = new ExpressionEvaluatingRequestHandlerAdvice();
    advice.setOnSuccessExpressionString("payload");
    advice.setOnFailureExpressionString("payload");
    advice.setTrapException(true);
    return advice;
  }

由于我没有指定的渠道流从建议，流是无处可去，需要一些东西，如. defaultOutputTo父母流（），以便它返回到父流与Message。

回答：

它工作了，但唯一的问题是，我仍然需要自定义头来获取原始有效负载，而不是请求失败有效负载/主体，以便流程继续。

@Bean
  public Advice expressionAdvice() {
    ExpressionEvaluatingRequestHandlerAdvice advice = new ExpressionEvaluatingRequestHandlerAdvice();
    advice.setOnSuccessExpressionString("payload");
    advice.setOnFailureExpressionString("headers['CUSTOM_KEY']");
    advice.setTrapException(true);
    advice.setReturnFailureExpressionResult(true);
    return advice;
  }

这就是我要找的。可能是更改变量名称，因为建议将在成功时返回，而不仅仅是失败的情况。

Answer 1

您还需要在ExpressionEvalue atingDemestHandlerAdwn中将this配置为true：

/**
 * If true, the result of evaluating the onFailureExpression will
 * be returned as the result of AbstractReplyProducingMessageHandler.handleRequestMessage(Message).
 *
 * @param returnFailureExpressionResult true to return the result of the evaluation.
 */
public void setReturnFailureExpressionResult(boolean returnFailureExpressionResult) {
    this.returnFailureExpressionResult = returnFailureExpressionResult;
}