Camel active mq - 生产者确认消息是否由消费者处理

Question

我们有一个生产者服务，它正在向主题发布消息，并且我们有 3 个消费者实例从主题中读取该消息。只有当所有消费者在另一个回复队列中处理并回复成功消息时，生产者才需要做进一步的处理（更新数据库）。即使其中一项消费者服务由于某些异常或回复队列中的任何失败消息而失败，生产者也不应该为该发布请求更新数据库。

对于下一个请求（主题中发布的新消息），如果所有消费者都在回复队列中处理并回复，则生产者应更新数据库。我们如何用骆驼和activemq实现这一点。是否有任何 EIP 模式可以实现这一目标？

任意

Answer 1

是的，生产者只需在回复队列上使用aggregator 企业集成模式即可确保所有 3 个消费者都处理了上一条消息。

文档：Apache Camel aggregator2 组件。

您将需要一个唯一键并使用适当的聚合策略。