骆驼事务JMS组件无法与聚合器一起使用

Question

我发现带有事务=真选项的JMS组件不能很好地与聚合器一起工作。我的路由是事务的，直到它到达聚合器，在聚合器之后，我的路由不再是事务的。如果我理解得很好，这是因为聚合器为每个交换转换启动新线程，这种行为停止了第一个事务线程，这导致事务提交和ack发送到队列。所以消息不再在队列中。这是正确的吗？

我用Camel需要做的是从一个队列(RabbitMQ)中读取所有消息，然后将它们全部转换到一个列表中，最后将列表中的数据写入文件。所有这些都必须是事务性的，如果在路由中发生了一些错误，消息应该留在队列中。基本上，到目前为止我所做的是用jms组件从队列中读取(使用选项transacted = true)，然后用聚合器聚合所有消息，然后发送到文件。

我的代码的简短示例：

from("jms:queue:someQUeue?transacted=true")
    // some more processing in the route                          <- route is transactional here
    .aggregate((constant(true)), new MyAggregationStrategy())
    .completionInterval(500)
    .process(new Processor() {                                    <- route is not transactional anymore
               // some processing
    })
    .toD("file://C/tmp...")

我认为最完美的组件是简单的JMS批处理，但是我们使用的是骆驼3.8，这个组件在这个版本和更新的版本中不再存在。为什么？有什么新的东西代替了这个吗？

SJMS和SJMS2也帮不了我，当我使用它们时，消费者不需要读取所有消息（队列中的所有消息都被解除锁定-等待被锁定），但是通过路由的处理仍然是一个接一个的消息。我如何使这成为一个交换，列出所有消息？

有没有其他的解决方法？(例如，创建一些自定义聚合器——但是如何实现呢？)

Answer 1

据我所知，这是正确的！如果您的意图是实现保证交付，在这种情况下，您最好使用持久聚合存储库。