消息聚合的Camel条件

Question

我正在寻找一种基于消息聚合的有条件处理消息的方法。我已经研究了很多方法来实现这一点，但似乎Apache Camel不支持它。我会解释这个场景，然后解释我尝试的解决方案。

• 我试图再次获取文件来处理它们。问题是，据我所知，你不能让消费者按需购买。我尝试使用pollenfrice，但它只能获取单个文件，而不是目录中的所有文件。
• 我试图筛选/停止父路由。这里的问题是filter()/choice...stop()/end()只会停止具有目录大小的聚合路由，而不会停止具有文件消息的父路由。我不能有条件地处理这些。
• 我试图将聚合条件移动到我将调用的另一个路由，但这会导致与第一个解决方案相同的问题。

我考虑做的事情：

• 重写聚合策略，以便不仅将大小聚合，还将文件本身聚合到一个GroupedExchange中。这样，我可以在检查之后再次拆分聚合。我真的不喜欢这个解决方案，因为它会导致很多样板文件，在运行时的代码中都是如此。
• 将文件大小计算器移到处理器而不是聚合器。这会首先挫败使用骆驼的目的…我会手动获取文件并添加大小…对于每一个文件都是如此..
• 使用ControlBus在该目录上动态启动删除路由。再一次，为了实现一些我认为应该可以通过简单路线完成的事情，我需要大量的变通方法。
• 我想设置每个父消息的计算大小，但我不知道如何实现？
• 另一种我没有想到的停止父路由的方法？

Answer 1

Camel真的很棒，但有时确实很难确定要使用哪种设计模式；）

首先，您需要保留文件对象的副本，因为在达到阈值之前，您不知道是否要删除它们--基本上（至少）有两种方法可以做到这一点。

备选案文1

第一种方法是在exchange属性中使用列表。无论您对exchange主体做什么，此属性都将一直存在。如果您查看GroupedExchangeAggregationStrategy的源代码，它可以做到以下几点：

        list = new ArrayList<Exchange>();
        answer.setProperty(Exchange.GROUPED_EXCHANGE, list);
        // ...
        list.add(newExchange);

也可以在自己的exchange属性上手动执行相同的操作。在任何情况下，都可以像您所做的那样使用分组聚合策略。

• 通过GroupedExchangeAggregationStrategy聚合以将单个文件保存在列表中
• 计算文件总大小（使用处理器，或使用自定义聚合策略）
• 使用筛选器（简单（“${body}<123”））
• 通过拆分器（简单（“${property.camelgroupedexchange}”））“展开”聚合
• 逐个删除文件

请让我知道，如果这是没有意义的，或者如果我误解了你的问题在任何方面。