Camel - Как остановить верблюжий маршрут, используя java dsl, при использовании компонента TIMER для объединения базы данных?

Question

Я пытаюсь остановить верблюжий маршрут, когда в базе данных больше нет данных для пула, но невозможно остановить.

from("timer://pollTheDatabase?delay=50s")
.routeId("db-pooling-route")
.to("mybatis:queryToSelectData?statementType=SelectOne")
    .choice()
        .when().simple("${in.header.CamelMyBatisResult} == ''").stop()
        .otherwise().to("direct:processing-data")
        .end()
    .end()
.end();

Answer 1

stop() означает прекращение маршрутизации текущего сообщения, а не самого маршрута. Для остановки / запуска маршрутов и т. Д. c вы можете использовать компонент controlbus.

https://camel.apache.org/components/latest/controlbus-component.html

А поскольку вы хотите остановить маршрут от самого себя, то установите параметр async=true в конечной точке шины управления.

Answer 2

Я пытался использовать контрольную шину, и она работала.

from("timer://pollTheDatabase?delay=50s&synchronous=false")
.routeId("db-pooling-route")
.to("mybatis:queryToSelectData?statementType=SelectOne")
    .choice()
        .when().simple("${in.header.CamelMyBatisResult} == ''")
        .to("controlbus:route?async=true&routeId=db-pooling-route&action=stop")
.end()
.to("direct:processing-data");