从多个源获取消息Apache Camel单路由

Question

我需要编写一条Apache Camel路由

null

我可以编写两条独立的路由：1）从Active-MQ获取消息；2）使用静态文件名读取文件夹中的文件并发送到JMS-Queue。但我的要求是只从这些文件中读取内容，对于这些文件，我从JMS队列中获取详细信息。这意味着从文件中读取内容是有选择的和基于条件的。

下面是我所需的示例Java DSL路由配置。

from("activemq:queue:filelocationQueue")
 .from("file://<<File-Location from JMS-Queue>>?noop=true")
   .convertBodyTo(String.class)
      .to("activemq:queue:fileContent");

我知道在一条路由内使用两个“from”是不可能的。但是我如何使用Apache Camel来实现这种逻辑呢？

伙计们请建议我的解决方案，我也准备用两条骆驼路由来实现这个逻辑。

Answer 1

您可以在处理器内部使用Camel的ConsumerTemplate来获取所需的内容，如下所示：

    from("activemq:queue:filelocationQueue")
    .process(new Processor() {

        public void process(Exchange exchange) throws Exception {

            // "file://<<File-Location from JMS-Queue>>?noop=true"
            String fileLocation = exchange.getIn().getBody(String.class);

            ConsumerTemplate template = getContext().createConsumerTemplate();
            // This is like your second "from". Use 2 second timeout (2000 ms).
            Exchange fileExchange = template.receive(fileLocation,2000);
            exchange.getOut().setBody(fileExchange.getIn().getBody());
            template.doneUoW(fileExchange);
        }
    })
    .convertBodyTo(String.class, "UTF-8")
    .to("activemq:queue:fileContent");

上面假设从filelocationQueue接收的消息正文包含要使用的文件的确切路径，例如file:/home/user/input？noop=true&fileName=file.txt。注意，您只能使用一个文件的唯一方法是使用fileName URI选项。否则您将消耗该文件夹中的所有文件。