我不了解虚拟主题在同一虚拟目的地的消费者上下波动的情况下的行为:
工作流程/情况
- 创建虚拟话题 => Virtual.A
- 创建虚拟队列的Consumer1(“Consumer group 1”)=> Consumer.CG1.Virtual.A
- 创建 Producer1 并将消息发送到 Virtual.A => Message1
- Consumer1 接收并确认 Message1
- 关闭消费者1
- 创建 Consumer2 到虚拟队列(“Consumer group 1”)=> Consumer.CG1.Virtual.A
观察到的行为
- Consumer2再次收到Message1
- 如果有多个消息,Consumer2接收所有消息
- 如果 Consumer2 在 Consumer1 还在运行时创建,它仍然会收到所有消息
期待
我本以为同一个虚拟队列的新消费者只会收到新消息,而不是全部再次接收。
问题
- 我正在寻找解释或参考文档来解释该特定行为。
- 有没有办法阻止这种行为,让ActiveMQ只发送虚拟队列未消费的消息?
- 最近的历史有多大?它会永远是虚拟主题仍然存在的一切吗?
提前致谢。