Apache Camel:OnCompletion和OneException查询

Question

在我的项目中，我想在每个新创建的路由上应用单独的OnComplection和OnException处理器。

假设我必须创建3条路线。对于每个路由，我准备了一个单独的RouteBuilder类，并进行如下配置-

onException(Throwable.class).handled(true).process(new ExceptionHandlingProcessor(RouteId)).maximumRedeliveries(2)
        .redeliveryDelay(1000).retriesExhaustedLogLevel(LoggingLevel.ERROR)
        .retryAttemptedLogLevel(LoggingLevel.WARN);

 onCompletion().process(new OnCompletionProcessor(RouteId)) ;

        from("sftp:Configuration").routeId("test")
        .choice()
            .when(body().isEqualTo(null))
                .process(new AgeCalculatingProcessor("test"))
            .otherwise()
                .to("file:configuration").log("Downloaded file ${file:name} complete.")
                ;

我的问题是……OneException和OnCompletion是在同一个route Builder类上创建的路由上工作（因为我在每个RouteBuilder类中只创建一个路由），还是将应用于上下文级别并在所有路由上工作？

实际上，我想在路由级别应用OneException和OnCompletion，但如果我在每个endpoint上应用OneException，我会遇到异常（比如-尝试将OneException移动到路由的顶部），如下图所示-

来自（sftp:conf）.OnException（Throwable.class）。restExceptionconf.to（文件：conf.OnException（Throwable.class）.restExceptionconf

Answer 1

RouteBuilder级别onException：如果您像这样定义onException处理程序

onException(...).log("This is RouteBuilder level exception handling.");

configure() {
    from(...).to(...);
}

它将处理同一RouteBuilder中所有路由的异常。

路由级别onException：如果您像这样定义onException处理程序

configure() {
    from(...)
    .onException(...).log("This is Route level exception handling.");
    .to(...);
}

它将成为路由级OneException处理程序，并且仅用于该单一路由上的异常。

路由级OneException定义将覆盖RouteBuilder级定义（例如，如果两者都定义了OneException（MyException.class），那么如果在该路由上引发了MyException，则只有在路由中直接定义的一个才会被调用）。

onComplection的行为方式与onException相同。

关于“尝试将OneException移动到路由顶部”的异常：您应该只在路由的开头定义OneException，如下所示：

from(sftp:conf).OnException(Throwable.class).restExceptionconf
   .to(file:conf);

进一步阅读此处的OneException和此处的onCompletion。