出现异常时如何停止骆驼路线。我的动态路由正在消耗 jms 并发送到响应式端点。
camelContext.addRoutes(New GenerateRoute());
路由生成器类如下：
public class GenerateRoute extends RouteBuilder {
@Override
public void configure() {
from("jms:queue:myQueue")
.toF("reactive-streams:myStream").setId("myRoute");
}}
【问题讨论】：
试试这个
from("jms:queue:myQueue")
.routeId("myRoute")
.doTry()
.toF("reactive-streams:myStream")
.doCatch(Exception.class)
.process(exchange -> exchange.getFromEndpoint().stop())
.end();
【讨论】：
您可以使用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#
【讨论】：
public class GenerateRoute extends RouteBuilder { onException(Exception.class).process(exchange -> { System.out.println("handling ex"); }).continued(false); @Override public void configure() { from("jms:queue:myQueue") .toF("reactive-streams:myStream").setId("myRoute"); } }
continued 所做的是处理异常。如果您想将控件返回到路由，则 continue 为 true，否则您可以将其设置为 false。如果handled 为真，则发生的异常将在交换中删除，否则它将保留在交换中，您仍然可以使用以下命令从交换中检索它：Throwable caused = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class); 这些是
direct:enrich-message，它丰富了消息，然后从direct:enrich-message发送到direct:send-to-mysystem，你发送如果您在direct:send-to-mysystem 的onException 子句中有continued=true 和handled=false，则将其发送到reactive-streams:myStream，则交换将被发送回direct:enrich-message 路由，并在交换中捕获异常。