Dear Camel users. Given the following DSL. What would be the best way to execute a task when all the below processing is complete?
Specifically, I have a second long running task that needs to get queued as soon as FOO2_QUEUE is complete. from(FOO_QUEUE) .to("bean:service?method=getFoo(${body})") .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { //All we care about is the citedArticle IDs list List<Long> ids = exchange.getIn().getBody(Foo.class).getIDs(); exchange.getOut().setBody(ids); } }) .split().body() //Create a job for each ID .to(FOO2_QUEUE) from(FOO2_QUEUE) .to("bean:service?method=foo");