您几乎可以正常工作了。这是您需要的更改（稍后我会解释）。
from("direct:aggregate").id("aggregate") .aggregate(property(AGGREGATION_PROPERTY), new BodyInAggregationStrategy()) .completionSize(property(Exchange.BATCH_SIZE)) .to("log:result", "mock:result")结果将是：
Exchange received, body: A+A+AExchange received, body: B+BExchange received, body: A
注意：
"Z"由于批次大小为，您将不会收到结果
7。
解释一下-如您所读， Aggregator 是一个通用的骆驼组件，正确定义的关键是：
- 聚合表达式
- 完成规则
现在，在你的情况你是聚合上的属性
AGGREGATION_PROPERTY，这将是
A，
B或
Z。另外，您要指定批次大小。
但是，您并未
completionSize()在路线中表达。取而代之的是，您使用了
completionFromBatchConsumer-做一些不同的事情（代码指出它在寻找
Exchange#BATCH_COMPLETE属性），因此结果很奇怪。
无论如何，
.completionSize(Exchange.BATCH_SIZE)将使您的测试按需运行。
祝你好运。
