Apache Camel-动态构建endpoint和endpoint

Question

from("activemq:queue:process" ).routeId("activemq_processqueue")
        .process(exchange -> {
            SomeImpl impl = new SomeImpl();
            impl.process(exchange);
        })
        .to(ExchangePattern.InOnly, "activemq:queue:upload");

在impl.process中，我正在填充ID和目标服务器路径。现在，我需要定义一个新的路由，它使用来自上传队列的消息，并复制一个本地文件夹（基于在上一个路由中生成的Id），并将其上传到目标文件夹，该文件夹是一个ftp服务器（这也在上一个路由中填充）

那么，如何设计一条新的路线，其中从和到终点都是动态的，如下所示？

from("activemq:queue:upload" )
        .from("file:basePath/"+{idFromExchangeObject})
    .to("ftp:"+{serverIpFromExchangeObject}+"/"+{pathFromExchangeObject});

Answer 1

对于您的情况，我认为有一个更好的替代方案，假设您使用的是比2.16更新的骆驼版本（以前的版本有替代方案，但更复杂，看起来不优雅-（例如consumerTemplate和recipientList））。

您可以用pollEnrich替换第一个“dynamic From”，它使用轮询使用者和简单的表达式构建动态文件endpoint来丰富消息。对于第二部分，如前所述，一个动态uri.tod将完成这项工作。所以您的路线如下所示：

 from("activemq:queue:upload" )
    .pollEnrich().simple("file:basePath/${header.idFromExchangeObject})
    .aggregationStrategy(new ExampleAggregationStrategy()) // * see explanation 
    .timeout(2000) // the timeout is optional but recommended
    .toD("ftp:${header.serverIpFromExchangeObject}/${header.pathFromExchangeObject}") 

>

请参见content enricher部分“使用动态URI”http://camel.apache.org/content-enricher.html。