Camel路由执行choice().when()后无法继续执行后续节点问题

你的核心问题是路由最后一行多余的.end();，破坏了整个路由的结构定义，导致choice()之后的所有步骤都没有被正确加载到路由中。

Camel中from()启动的路由是链式调用结构，不需要手动调用.end()来闭合路由——链式调用到最后一个处理器（比如你的.bean(dao, "save")）就已经完成了路由定义，额外的.end()会错误地终止路由上下文，使得后续的log、postProcessor和save方法都不会被执行。

修正后的代码 #

from(getEndpoint())
    .id(endpoint)
    .filter(notDeleted)
    .process(get)
    .filter(exists)
    .choice()
        .when(hasProperty)
            .wireTap("direct:" + AlternateRoute.ENDPOINT)
    .end() // 正确结束choice分支
    .log("Got here")
    .process(postProcessor)
    .bean(dao, "save"); // 移除多余的.end()

额外排查点 #

• 确认filter(notDeleted)和filter(exists)的条件是否确实满足：如果这两个过滤器有一个不通过，会直接跳过后续所有步骤，你可以在过滤器前后添加日志来验证。
• wireTap是异步分流逻辑，主线程不会等待AlternateRoute的执行，只要前面的条件满足，主线程会立刻继续执行log及后续步骤，不存在阻塞问题。
• choice()的结束使用.end()是正确的，endChoice()仅用于嵌套的choice场景，你的场景不需要使用它。

内容的提问来源于stack exchange，提问作者JaAnTr