アグリゲーターを使ってチェックファイルがすべてのラクダルートで処理されます

Question

私はラクダアプリケーションを持っていますが、私はFTPソースからファイルを読み込んでいます。 ファイルが複数のルートを通過するように、1つのルートが保管のためにcassandraに行き、1つのルートがデータを処理し、ピボットデータをKafkaトピックにプッシュするなど

すべてのルートと到達最後まで。このようにして、ファイル名に基づいて処理済みログを構築することができます。私が考えることができる

一つの方法は、各ルートが交換ヘッダに完了通知を送信し、その後、処理され、アグリゲータで完了条件ロジックに基づいて、私はそのファイルをマークするアグリゲータを実現することです。

このようなアグリゲータはどのようにJavaで記述しますか？

Answer 1

multicastを試してみることができます。

from("direct:start") 
    .multicast() 
     .to("direct:a","direct:b") 
    .end() 
    // Won't run until the sub routes are complete 
    .process(new MarkFileAsCompletedProcessor()) 
    .log("Finished multicast"); 

from("direct:a") 
    .log("Processing a") 
    .to("mock:endOfA"); 

from("direct:b") 
    .log("Processing b") 
    .to("mock:endOfB");