14.4. 启用消息重新发布

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 在 & lt;cluster-connection& gt; 元素中，验证 <message-load-balancing > 是否已设置为 ON_DEMAND。

   <configuration>
       <core>
           ...
           <cluster-connections>
               <cluster-connection name="my-cluster">
                   ...
                   <message-load-balancing>ON_DEMAND</message-load-balancing>
                   ...
               </cluster-connection>
           </cluster-connections>
       </core>
   </configuration>

3. 在 &lt ;address-settings > 元素中，为队列或一组队列设置 redistribution delay。

   在本例中，在最后一个消费者关闭后，负载均衡到 my.queue 的消息将被重新分发 5000 毫秒。

   <configuration>
       <core>
           ...
           <address-settings>
               <address-setting match="my.queue">
                   <redistribution-delay>5000</redistribution-delay>
               </address-setting>
           </address-settings>
           ...
       </core>
   </configuration>

   address-setting

   将 match 属性设置为您要重新分发消息的队列名称。您可以使用代理通配符语法来指定队列范围。更多信息请参阅 第 4.2 节 “将地址设置应用到一组地址”。

   redistribution-delay

   代理在将此队列的最终消费者关闭后应等待的时间（以毫秒为单位），然后再将消息重新分发到集群中的其他代理。如果将其设置为 0， 则信息将立即重新分发。但是，您应该在 redistributing 前设置一个延迟 - 消费者通常关闭，但同一队列中需要快速创建另一个。

4. 对集群中的每个额外代理重复此步骤。