使用 Apache Camel 在一个事务中从 activemq 收集

问题描述

我喜欢做什么：

1. 在一个事务中从队列中侦听和获取消息。
2. 过滤和收集消息。
3. 当收到特定数量的消息或超时时，它们应该被发送到另一个队列。当它们成功转移到下一个队列时，应该提交事务。

我想出了什么：

from("activemq:queue:collect?transacted=true")
    .transacted()
    .aggregate(new FilterandCollectAggregationStrategy())
        .completionInterval(10000L)
        .completionSize(1000)
    .to("activemq:queue:process");

问题： 为每条消息创建一个新事务，并在发送到聚合器时自动提交。 发送到“进程”队列时提交的所有消息如何获取一个事务？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）