集約のメッセージサイズに基づく集計方法

Question

私は交換を集約したいと思います。そして、ある特定のサイズ（例えば20KB）のヒットを交換すると、その交換をクローズとしてマークしたいと思います。

私はエクスチェンジのサイズをチェックする初歩的な実装をしていますが、それが18KBの場合は私の述語から真を返します。しかし、メッセージが4KBで現時点で17KBであれば、それは大きすぎる21KBのときに集約することを意味します。

これを解決する方法はありますか？集計戦略で何かをして結合を拒否し、集約するために新しいExchangeを開始することはできますか？

実際のサイズを確認するために別のプロセスを実行してメッセージの末尾のメッセージを削除してサイズに合わせることができたと考えていましたが、削除されたメッセージごとに戻します...しかし、私は常に実行する可能性が高いルーチンを補償している。

ご協力いただきありがとうございます。

Answer 1

私は17 + 4> 20の状況があるときにそれを完全とマークするために使用できる熱心な完全なオプションがあると思います。そして、それは17を完了し、でドキュメントを参照してください。4.

と新しいグループを開始します：https://github.com/apache/camel/blob/master/camel-core/src/main/docs/eips/aggregate-eip.adoc

そして、あなたはまた、おそらく `PreCompleteAggregationStrategy」を使用し、その17 + 4にtrueを返す必要があるだろう>それ以外の場合は、最初にまとめてグループ化して21になります。しかし、熱心な完了チェックオプションとこのインターフェースを使用することで、必要に応じて行うことができます。

https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java