阿帕奇骆驼多个消费者

Question

我已经和ApacheCamel合作了一段时间，做了一些基本的工作，但现在我正在尝试创建一个路由，在该路由中，我可以让多个“消费者”访问同一条路由，或者在路由中添加一个消费者，然后处理消息。

我的想法是拥有一个由事件触发的事件驱动消费者，然后例如从ftp读取文件。我正计划做这样的事情：

from("direct:processFile")
  .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.");

所以这个想法是我有一个事件（例如直接或来自消息队列），它具有“fileName”属性，然后使用该属性从ftp下载/使用具有该名称的文件。

我相信问题是在同一路由中拥有from（）.from（），但问题是如果我将ftp组件留在“to”中，那么我的队列事件将被写入ftp中的文件中，这与我想要的相反;它的行为是生产者而不是消费者。

有没有可能的方法来实现我想要做的事情，或者它与骆驼的用途相冲突？

Answer 1

像这样的怎么样？

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

Answer 2

多亏了Claus Ibsen的评论，我找到了我正在寻找的东西，我需要的组件和使其工作的组件是内容丰富器。

这是对我有用的路线：

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