Camel 2.11批处理聚合如何与单独的路由一起工作？

Camel 2.11批处理聚合如何与单独的路由一起工作？

您几乎可以正常工作了。这是您需要的更改（稍后我会解释）。

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)

将使您的测试按需运行。

祝你好运。