0

我有一个发出 API 请求的骆驼路线,外部服务可能是 4xx 或 5xx。我已经编写HttpOperationFailedException了处理程序来处理所有与 HTTP 相关的异常,并且我正在重试所有 Http 异常,无论它是客户端还是服务器端异常。我想以某种方式处理它们,我需要避免客户端异常的reties。

这是我的路线和异常代码,看起来像。任何人都可以建议处理这些情况的最佳方法吗?


  onException(HttpOperationFailedException.class)
        .handled(true)
        .redeliveryDelay(100)
        .maximumRedeliveries(2)
        .log("${exception} Http Communication Exception while making API request")
        .end();


from("direct:start")
        .routeId("restApi")
        .process(exchange -> exchange.getIn().setBody(
            new RequestBody(
                "${headers.camelFileName}")))
        .marshal()
        .json(JsonLibrary.Gson)
        .setHeader(Exchange.HTTP_METHOD, constant("POST"))
        .setHeader("Content-Type",constant("application/json"))
        .to(url)
        .end();
4

1 回答 1

2

您可以尝试以下方式:

        onException(HttpOperationFailedException.class)     
                .choice()
                    .when(simple("${exception.getStatusCode()} == '400'"))
                     //doSomething
                    .endChoice()
                    .when(simple("${exception.getStatusCode()} == '500'"))
                     //doSomething
                    .otherwise()
                    //retries
                    .endChoice()
                .end()
        ;
于 2022-01-25T08:45:50.170 回答