Apache Camel以嵌套拆分方式加入所有交换

Question

我对Apache Camel相当陌生，有几个问题。我希望我的路线做到以下几点:

• 在加载列表中加载列表
• 拆分两次，这样我就可以处理内部列表中的每个项目
• 过滤掉一些我不需要的东西
• 从内部分裂加入所有剩余的交换
• 然后最终再次加入（回到一个交易所）

我的路线如下所示：

from("direct:myRoute")
    .process(new LoadSomeThingsProcessor())
    .split(body())
    .streaming()
    .process(new SomeProcessor())
    .split(body())
    .streaming()
    .filter(new SomeFilter())
    .aggregate(header("myHeader", new MyAggregationStrategy())
    .completionPredicate(new MyCompletionPredicate())
    // more processors
    // aggregate again (should just be one exchange after this point
    // more processors
    .to("direct:someOtherRoute");

MyCompletionPrediate的匹配method只是：

return exchange.getIn().getProperty("CamelSplitComplete", Boolean.class);

我想确保在我继续之前，每个拆分中的所有交换都聚合在一起。

我的问题是：-CamelSplitCompl头从来都不是真的。什么会导致这种情况？-试图在嵌套拆分中聚合会导致任何问题吗？-如果最后一个交换（应该有CamelSplitCompl=true的交换被过滤掉会发生什么？我怎么知道我已经将所有的交换聚合在一起了？-这是解决这个问题的正确方法吗？如果没有，我还应该考虑什么？

仅供参考，我的聚合策略只是将新交易所的主体添加到旧交易所的主体中。

先谢过了。

Answer 1

请参阅合成消息处理器EIP：https://camel.apache.org/components/latest/eips/composed-message-processor.html

并且有一个标题为“仅拆分器”的示例，它允许执行分叉/连接样式。您仍然可以在拆分器中使用过滤器来过滤特定项目等。

尽量不要把它弄得太复杂，有2倍的分割和各种各样的东西——保持它简单一点，然后它更容易使用，测试和工作。