0

如果我有一个无状态的消息消费者，它正在等待几条异步消息的到来，在开始处理从它们那里获得的数据之前，我如何确保我已经收到了所有消息？换句话说，我要么需要绑定到特定会话的中间状态存储，要么需要类似waitForAll().

ActiveMQ 在这个方向上提供了什么？

4

1 回答 1

0

您不能对从用户收到的每条消息使用某种计数器吗？当计数器达到您期望的消息数量时，请执行您需要执行的任何操作。

你能给我们更多关于你想要做什么的信息吗？

于 2013-11-07T13:31:37.077 回答