現在Apache Camelを使用しています
次の場合、集計がいつ完了したかを判断する方法がわかりません。
- 多くの部分からなるメッセージから始めます
- その後、メッセージは複数の部分に分割されます
- これらのメッセージの一部はフィルターで除外されます
- 残りのメッセージは変換されます
- 次に、メッセージをグループ化して 1 つのメッセージに戻します。
入ってくるメッセージの数を知っています。フィルター処理をしなければ、アグリゲーターはそれだけの数のメッセージを待つことができます
ここに私のアイデアのいくつかがありますが、どれもあまり好きではありません
- フィルターは、予想されるメッセージの数を示すメッセージをアグリゲーターに送信します
- フィルターはフィルターではなく、フィルター処理されるすべてのメッセージをアグリゲーターに直接送信し、アグリゲーターはフィルターとして機能します