ActiveMQ / JMS内置机制,可确保共享公共头(即JMSXGroupID头)的消息在使用竞争消费者模式时始终由队列的同一消费者消耗。队列的消费者对实际头值完全不知情,因为确保具有公共头的消息是在服务器端而非消费者端执行的。有关此功能的详细信息,请参见http://activemq.apache.org/message-groups.html。
在AMQP或特定于RabbitMQ的内容中是否可能做到这样的事情?
ActiveMQ / JMS内置机制,可确保共享公共头(即JMSXGroupID头)的消息在使用竞争消费者模式时始终由队列的同一消费者消耗。队列的消费者对实际头值完全不知情,因为确保具有公共头的消息是在服务器端而非消费者端执行的。有关此功能的详细信息,请参见http://activemq.apache.org/message-groups.html。
在AMQP或特定于RabbitMQ的内容中是否可能做到这样的事情?
参考文献:https://github.com/rabbitmq/rabbitmq-server/issues/262和https://twitter.com/old_sound/status/410898209788411904