Apache Camel / EIP过滤后的聚集

Question

我目前正在使用Apache Camel

在下面的情况下，我不确定如何确定聚合何时完成。

• 首先是一些包含许多部分的消息。
• 然后，该消息被拆分为它的各个部分。
• 然后，这些消息中的一些被过滤掉。
• 其余的消息被转换。
• 然后，我们希望将消息分组回一条消息中。

我们知道有多少消息进来了，如果我们不过滤聚合器，就可以等待这么多消息。

以下是我的一些想法，我真的不喜欢其中任何一个

• 过滤器会向聚合器发送一些消息，该聚合器会告诉您预期的消息数量。
• 过滤器不是过滤器，它直接将过滤后的所有消息发送给聚合器，聚合器充当过滤器。

Answer 1

请参阅只包含拆分器的组合消息处理器示例。

• http://camel.apache.org/composed-message-processor.html

如果使用筛选器，则如果exchange是否已过滤，则筛选器将在exchange上设置一个属性。然后，您可以在聚合策略中使用该信息来了解是否要将该消息合并到该单个结果消息中。

请参阅了解交易所是否已过滤或未在

• http://camel.apache.org/message-filter.html