java - 在JMS队列中实现ActiveMQ的粘性 session (消息组)

Question

我正在尝试摆脱 ActiveMQ，但我们想要保留的一项功能是消息组。通过将 session ID 添加到 JMS header ，ActiveMQ 会将队列上具有相同 ID 的所有其他消息路由到同一消费者(我们的消费者可能位于不同的机器上)，从而允许接收者将一组消息视为一个工作单元。

我的第一个想法只是将 session 置于 CLIENT_ACKNOWLEDGE 模式。我的想法是，如果消费者 A 查看 header 并发现它不是它正在处理的 ID，那么它可以直接删除该消息，而消费者 B 会拾取该消息。我遇到了几个问题，包括 ActiveMQ 的完善，而且我读得越多，就越觉得这不是最初设计的目的。

我能想到的一个想法是建立一个调度队列，然后将消息路由到每个消​​费者的，因为缺乏更好的词，子队列并管理将 session ID 与子队列匹配。

在我走这条路之前，我们对此持怀疑态度，因为它会增加代码的复杂性，然后我们想要，关于 CLIENT_ACKNOWLEDGE 是否有我遗漏的东西？或者我应该先尝试其他完全不同的东西？

Answer 1

这就是你想要做的http://docs.redhat.com/docs/en-US/JBoss_Enterprise_Application_Platform/5/html-single/HornetQ_User_Guide/index.html#message-grouping