Как остановить верблюжий маршрут, если есть исключение. Мой динамический маршрут потребляет 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 равно false, маршрутизация не вернется к исходному маршруту.
DSL:
<onException>
<exception>java.lang.IllegalArgumentException</exception>
<continued><constant>false</constant></continued>
</onException>
Ява:
onException(IllegalArgumentException.class).continued(fasle);
См.: https://camel.apache.org/manual/latest/exception-clause.html#
continued, так это обработка исключения. Если вы хотите вернуть элемент управления обратно на маршрут, тогда продолжение равно true, в противном случае вы можете установить его как false. Если handled истинно, возникшее исключение будет удалено в обмене, в противном случае оно останется в обмене, и вы все равно сможете получить его из обмена, используя: Throwable caused = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class); Это
- person Poorya Hosseini; 01.07.2020
direct:enrich-message, который обогащает сообщение, а затем изdirect:enrich-message вы отправляете его в direct:send-to-mysystem, откуда вы отправляете его в reactive-streams:myStream, если у вас есть continued=true и handled=false в предложении onException direct:send-to-mysystem, тогда обмен будет отправлен обратно на маршрут direct:enrich-message с перехваченным исключением в обмене.
- person Poorya Hosseini; 01.07.2020
