Apache CamelアグリゲーターとonCompletionの組み合わせ

Question

完了サイズとそれに続くタイムアウトによってトリガーされたすべての集約された交換が処理された後にonCompletionを実行します。しかし、完了サイズがトリガされた直後に、タイムアウト基準によってトリガされるのを待っている交換機の一部が発生します。

Answer 1

Iは .onCompletion（（fromEndPoint）から

として設定されたルートを持っている） .doSomething（） .split（）//各行 .streaming（） .parallelProcessing（） .unmarshal （）.bindy .aggregate（） .completionSize（100） .completionTimeout（5000） .TO（toEndpoint）スプリットは405本のライン、凝集の最初の4組で行った場合

仮定交換は400回線（交換）を完了するエンドポイントに行きます。そして、それはすぐにonCompletionをトリガーします。しかし、completionTimeout基準が満たされたときにトリガーされる集約されたエクスチェンジはまだ5つあります。 5つの交換機がtoエンドポイントにルーティングされた後、onCompletionがトリガーされませんでした。

ここで私の質問は、オンコンプリーションが各交換ごとに、またはすべての後にトリガーされるべきです。

注：ここでのエンドポイントのマイファイルはファイルです。