Apache Camel - エンドポイントとエンドポイントを動的に構築する

Question

私はprocess queueのメッセージを処理してupload queueに送信するラクダルートを持っています。 impl.processで

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

私はIdとdestination server pathを移入しています。今、私はアップロードキューからメッセージを消費し、ローカルフォルダをコピーする新しいルートを定義する必要があります（以前のルートで生成されたIdに基づいて）そしてそれをftpサーバである宛先フォルダにアップロードしてください（これも以前のルートにあります）

エンドポイントとエンドポイントの両方が動的で、以下のような新しいルートを設計するにはどうすればよいですか？

キャメルにエンドポイントに動的に追加

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

Answer 1

私は2.16より新しいCamelバージョンを使用していることを認めて、あなたのケースには良い選択肢があると思います（以前のバージョンの代替は存在しますが、より複雑であり、 consumerTemplate recipientList）。

ポーリングコンシューマとシンプルな式を使用してメッセージを豊かにするpollEnrichを、ダイナミックファイルエンドポイントを構築するために置き換えることができます。 .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}") 

1. コンテンツのエンリッチャセクション「動的なウイスルを使用する」 http://camel.apache.org/content-enricher.htmlを参照してください。

   元の交換をリソース交換と組み合わせて、集約後に集約された交換にヘッダーserverIpFromExchangeObject、pathFromExchangeObjectが含まれるようにするには、集約戦略が必要です。カスタム戦略を含まない場合、Camelはデフォルトでリソースから取得した本体を使用します。これがどのように動作するかは、content-enricher.htmlのExampleAggregationStrategyの例を参照してください。 .TODについては

2. は（）私はそれが可能だとは思わないhttp://camel.apache.org/how-to-use-a-dynamic-uri-in-to.html

Answer 2

は（コメントで述べたように）私は任意fromD()同等の知らないon this page on the Camel site. に記載されている.toD()で行うことができます。ただし、CamelContextのaddRoutesメソッドを呼び出すと、動的ルートを追加できます。これについては、this page on the Camel site.

ここでは、Camelサイトの例を少し拡大すると、正しい方向に向かうべきものがあります。

public void process(Exchange exchange) throws Exception { 
    String idFromExchangeObject = ... 
    String serverIpFromExchangeObject = ... 
    String pathFromExchangeObject = ... 

    exchange.getContext().addRoutes(new RouteBuilder() { 
     public void configure() { 
      from("file:basePath/"+ idFromExchangeObject) 
      .to("ftp:"+ serverIpFromExchangeObject +"/"+pathFromExchangeObject); 
     } 
    }); 
} 

このフレームワークには驚くほど多くのEIPと機能があるため、Camelには他にもオプションがあります。