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

Question

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

camelContext.addRoutes(New GenerateRoute());

路由生成器class如下：

public class GenerateRoute extends RouteBuilder {

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

Answer 1

您可以使用 handled 和 continued。在 onException 子句中。 “Continued 允许您在原始路由中处理和继续路由，就好像没有发生异常一样。”如果 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#

Answer 2

试试这个

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

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

How to stop camel dynamic route on exception

apache-camel

spring-camel