Apache Camel多消费者

多亏了 comment from Claus Ibsen 我找到了我想要的东西,我需要的组件,使它工作的是 Content Enricher .

以下是对我有效的途径:

from("direct:processFile")
  .pollEnrich().simple("ftp://localhost:21/folder?fileName=${body.fileName}")
  .log("Start downloading file ${file:name}.")
  .unmarshal().bindy(BindyType.Csv, MyFile.class)
  .to("bean:fileProcessor")
  .log("Downloaded file ${file:name} complete.");

像这样的怎么样?

  .from("direct:processFile")
  .transform(simple("${body.fileName}"))
  .from("ftp://localhost:21/folder?fileName=${body.fileName}") // etc.
  .log("Start downloading file ${file:name}.")
  .unmarshal().bindy(BindyType.Csv, MyFile.class)
  .to("bean:fileProcessor")
  .log("Downloaded file ${file:name} complete.");