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");

Reply via email to