java - Camel 聚合器 completionSize 与 correlationExpression？

Question

给定以下 Camel 聚合器(通过 Spring XML):

<aggregate strategyRef="myggregationStrategy" completionSize="3">
    <correlationExpression> 
        <simple>${header.id} == 1</simple> 
    </correlationExpression>
    <to uri="bean:postProcessor?method=process" />
</aggregate> 

completionSize、correlationExpression 和何时调用 myAggregationStrategy#aggregate 方法之间有什么关系？当 3 条消息到达聚合器时，是否调用 aggregate？ correlationExpression 是否充当某种过滤器？它们如何相互协作？

Answer 1

AggregationStrategy::aggregate() 会为与相关表达式匹配的每个交换调用。关联表达式用于关联传入的消息。 IE。以确定传入消息属于哪个更大的实体。如果较大实体的各个部分散布在一起，那么您可能会并行组装多个实体，并且相关表达式会将它们分开。

完成大小是一种告诉聚合器您正在组装的较大实体已完成并且它应该沿路线继续聚合交换的一种方式。请参阅 this page 上的“关于完成”一章.

AggregationStrategy::aggregate() 会为每条与相关表达式匹配的传入消息调用。

也看看这个 example .