Camel在动态完成大小上使用聚合和完成

Question

嗨，我有一个骆驼路线，它分割一条传入的消息，然后我想聚合这条消息，但我不知道会分割多少条消息。

我使用了以下方法:

.aggregate(new AggregateStrategy()).header("uuid").completionSize(header("CamelSplitSize"))

这不起作用，而且挂起了……不过，如果我将完成大小设置为一个数值，它就起作用了。

有人知道如何动态聚合，并等待完成。顺便说一下，标题是在分割之前设置的。

Answer 1

您不需要聚合器，也不需要完成大小。您只需要一个具有聚合策略的拆分器EIP。

在链接的示例中，您可以看到这样的拆分器会对之前拆分的内容进行重新聚合。无论分割产生了多少部分。

// a Splitter with an AggregationStrategy
.split([yourSplitCriteria], new MyAggregationStrategy())
    // each splitted message part is sent to this bean 
    .to("bean:PartProcessor")
    // you can do whatever you want in here
    // end the split to re-aggregate the message parts
.end()
// here, after the split-ending you get the re-aggregated messages