异常处理 Camel Apache

Question

我是 Camel Apache 的新手，在异常处理方面遇到了一些麻烦。我要做的是捕获 SalesforceException，然后我需要根据 statusCode 采取不同的操作。

例如，当statusCode >= 500 时，我必须尝试重新发送消息。这是一个技术错误。当 statusCode < 500 时，我必须合并请求和响应并将其放在 failureQueue 中。

所以我的问题是：我如何尝试在选择定义中重新传递消息？似乎无法使用可以在 onException 上使用的以下选项：

          .handled(true).useOriginalMessage().maximumRedeliveries(3)
          .redeliveryDelay(5000)
          .logRetryAttempted(true)
          .retryAttemptedLogLevel(LoggingLevel.WARN)

我也尝试抛出我自己定义的新异常，以便我可以从那里处理它，但看起来 FatalFallbackErrorHandler 接管了我没有权力，因为我无法自己处理它。所以我的第二个问题 - 如果在选择定义中没有重新发送它的答案 - 我如何在自定义异常中处理它而不由 ErrorHandler 接管？

这是我的代码：

    onException()
         .logStackTrace(true);


    onException(SalesforceException.class)
                .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    SalesforceException cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, SalesforceException.class);
                    exchange.setProperty("statusCode", cause.getStatusCode());
                    exchange.setProperty("response", cause.getMessage());
                }
            })
            .choice()
                .when(header("statusCode").isGreaterThanOrEqualTo(500))
        // try to redeliverd the orginal message
                    .log(LoggingLevel.WARN, "{{logger}}", "Salesforce exception caught with statusCode >= 500")
                    .throwException(new SalesforceTechnicalException()) 
                .otherwise()
        // combine request & response and put on failurequeue
                    .log(LoggingLevel.WARN, "{{logger}}", "Salesforce exception caught with statusCode < 500, following message will be put on failure queue")                                                  
                    .throwException(new SalesforceFunctionalException())     
            .end();

    onException(SalesforceTechnicalException.class)
    //combine request & response and put on failurequeue
            .transform(ExpressionBuilder.simpleExpression("{\"request\" : ${exchangeProperty.requestBody}, \"response\" : ${exchangeProperty.response}}"))
            .to("log:{{logger}}?level=INFO&showHeaders=true")
            .to("amqp:qFailure?exchangePattern=InOnly");

    onException(SalesforceTechnicalException.class)
    //try resending the orginal message to SF Rest API
            .useOriginalMessage()
            .handled(true)
            .maximumRedeliveries(3)
            .redeliveryDelay(5000)
            .logRetryAttempted(true)

Answer 1

您应该能够使用一对 onException(SalesforceException.class) 块并使用 onWhen(Predicate) 缩小每个块的范围。

    onException(SalesforceException.class)
        .onWhen(new Predicate() {

            @Override
            public boolean matches(Exchange exchange) {
                SalesforceException cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, SalesforceException.class);
                return cause.getStatusCode() < 500;
            }
        })
        .log("Handled here if statusCode < 500")
        .useOriginalMessage()
        .handled(true)
        .maximumRedeliveries(3)
        .redeliveryDelay(5000)
        .logRetryAttempted(true);

    onException(SalesforceException.class)
        .onWhen(new Predicate() {

            @Override
            public boolean matches(Exchange exchange) {
                SalesforceException cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, SalesforceException.class);
                return cause.getStatusCode() >= 500;
            }
        })
        .log("Handled here if statusCode >= 500")
        .transform(ExpressionBuilder.simpleExpression("{\"request\" : ${exchangeProperty.requestBody}, \"response\" : ${exchangeProperty.response}}"))
        .to("log:{{logger}}?level=INFO&showHeaders=true")
        .to("amqp:qFailure?exchangePattern=InOnly");

异常处理 Camel Apache

Exception handling Camel Apache

java

exception-handling

exception

salesforce

apache-camel