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

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);