在時間範圍內的Apache Camel聚合消息

Question

有沒有什麼方法可以在Apache Camel的時間範圍內聚合消息。 我想通過向其中推送消息並從其他方消耗來計算我的系統的即時TPS。 在消費者方面，我想製作一個聚合器，它聚合了在某個時間範圍內傳遞的消息（可以說1秒）並提供一些計算。

到目前爲止，我可以看到駱駝提供聚合觸發的不活動超時處理。

謝謝。

Answer 1

看到Camel's aggregator EIP正是這種...

from("direct:start") 
    .aggregate(constant(true), new MyAggregationStrategy()).completionInterval(1000) 
     .to("mock:aggregated");