如何解决使用 Apache Camel 在一个事务中从 activemq 收集
我喜欢做什么:
- 在一个事务中从队列中侦听和获取消息。
- 过滤和收集消息。
- 当收到特定数量的消息或超时时,它们应该被发送到另一个队列。当它们成功转移到下一个队列时,应该提交事务。
我想出了什么:
from("activemq:queue:collect?transacted=true")
.transacted()
.aggregate(new FilterAndCollectAggregationStrategy())
.completionInterval(10000L)
.completionSize(1000)
.to("activemq:queue:process");
问题: 为每条消息创建一个新事务,并在发送到聚合器时自动提交。 发送到“进程”队列时提交的所有消息如何获取一个事务?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。