根据实际路线选​​择骆驼

Question

我有两条单独的路线。两条路线基本相同。不同的是源文件夹和目标文件夹。如果发生错误，两条路由都会抛出相同的异常。这我在一个 onException 块中捕获。 在此，我想根据实际路线将文件写入文件夹。所以我想基于 routeId 构建一个 choiche()....when(...) 。问题是，我怎样才能让 routeId 在何时使用它。 下面显示了一些我认为它如何工作的代码。但不是。也许有人有一个想法。

           onException(SomeValidationException.class)
                        .handled(true)
                        .useOriginalMessage()
                        .choice()
                        .when(exchangeProperty("routeId").convertToString().isEqualTo("Route1"))
                        .to("file:data/error/Route1")
                        .when(exchangeProperty("routeId").convertToString().isEqualTo("Route2"))
                        .to("file:data/error/Route2")
                        .otherwise()
                        .log(LoggingLevel.ERROR, "I always get here")
                        .end();

                from("file:data/in/Route1")
                        .routeId("Route1")
                        .routePolicy(getRoutingPolicy())
                        .to("direct:RouteWhichWillThrowException")
                        .to("file:data/out/Route1");

                from("file:data/in/Route2")
                        .routeId("Route2")
                        .routePolicy(getRoutingPolicy())
                        .to("direct:RouteWhichWillThrowException")
                        .to("file:data/out/Route2");

Answer 1

我认为您的用例实际上最好使用如下的路由错误处理程序：

from("file:data/in/Route1").routeId("Route1")
    .onException(SomeValidationException.class)
        .handled(true)
        .useOriginalMessage()
        .to("file:data/error/Route1")
        .log(LoggingLevel.ERROR, "I always get here")
     .end()
    .routePolicy(getRoutingPolicy())
    .to("direct:RouteWhichWillThrowException")
    .to("file:data/out/Route1");

from("file:data/in/Route2").routeId("Route2")
    .onException(SomeValidationException.class)
        .handled(true)
        .useOriginalMessage()
        .to("file:data/error/Route2")
        .log(LoggingLevel.ERROR, "I always get here")
     .end()
     .routePolicy(getRoutingPolicy())
     .to("direct:RouteWhichWillThrowException")
     .to("file:data/out/Route2");

然而，虽然这在重用方面是可行的，但如果您的实现除了 inputURI、outputURI 和 errorURI 之外总是相同的，那么这种情况就很糟糕了。我建议创建一个模板路由，然后创建它的新实例。

class MyCustomRouteBuilder extends RouteBuilder {
    private String myRouteId;
    private String inputURI;
    private String outputURI;

    @Override
    public void configure() {
        from(inputURI).routeId(myRouteId)
            .onException(SomeValidationException.class)
                .handled(true)
                .useOriginalMessage()
                .to(errorURI)
                .log(LoggingLevel.ERROR, "I always get here")
             .end()
             .routePolicy(getRoutingPolicy())
             .to("direct:RouteWhichWillThrowException")
             .to(outputURI);
    }
}

//different route builder configure
MyCustomRouteBuilder route1 = new MyCustomRouteBuilder();
route1.setRouteId("");
route1.setInputURI("");
route1.setOutputURI("");
route1.setErrorURI("");
context.addRoutes(route1);