11.2. 自动消息分组
您可以通过自动生成 ID,而不是自己提供组 ID。以这种方式分组的消息仍然由一个消费者按顺序处理。
步骤
以下示例演示了如何使用核心 JMS 客户端启用消息分组。
启用自动生成组 ID。
如果您使用 JNDI 上下文环境来实例化 JMS 连接工厂,请将
autogroup=true
name-value 对添加到连接 URL 的查询字符串中。java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory connectionFactory.myConnectionFactory=tcp://localhost:61616?autoGroup=true
如果您不使用 JNDI,请在
ActiveMQConnectonFactory
上将autogroup
设为true
。ActiveMQConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithoutHA(...); cf.setAutoGroup(true);