如何在异常时停止camel动态路由

Question

如何在出现异常时停止驼峰路由。我的动态路由是使用jms并发送到反应式端点。

camelContext.addRoutes(New GenerateRoute());

路由生成器类如下：

public class GenerateRoute extends RouteBuilder {

@Override
public void configure() {
    from("jms:queue:myQueue")
        .toF("reactive-streams:myStream").setId("myRoute");
}}

Answer 1

尝尝这个

    from("jms:queue:myQueue")
            .routeId("myRoute")
            .doTry()
                .toF("reactive-streams:myStream")
            .doCatch(Exception.class)
                .process(exchange -> exchange.getFromEndpoint().stop())
            .end();

Answer 2

您可以使用handled和continued。在onException子句中。“继续允许您处理和继续原始路由中的路由，就像未发生异常一样。”如果continued为false，则路由不会返回到原始路由。

DSL：

<onException>
    <exception>java.lang.IllegalArgumentException</exception>
    <continued><constant>false</constant></continued>
</onException>

Java：

onException(IllegalArgumentException.class).continued(fasle);

请参阅：https://camel.apache.org/manual/latest/exception-clause.html#