我想使用静态主机在我的双节点群集上启用消息重新分配。但它似乎并不奏效。ArtemisMQ 2.x上的消息重新分配不起作用
1)我有10个生产者写入队列“MyTestQueue”节点1(但没有消费者)。
2)我在节点2(但没有生产者)上有1个消费者使用来自节点2的消息。
我期望节点1将消息重新分配给消费者存在的节点2,但它不会。节点1上的消息数量仍然等于发送到节点1的消息数量。
我在broker.xml中拥有以下配置,它将forward-when-no-consumers
设置为false。 我也设置redistribution-delay
值为零。
<jms xmlns="urn:activemq:jms">
<queue name="MyTestQueue"/>
</jms>
...
<cluster-connections>
<cluster-connection name="my-test-cluster">
<address>jms</address>
<connector-ref>server0-connector</connector-ref>
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<forward-when-no-consumers>false</forward-when-no-consumers>
<message-load-balancing>ON_DEMAND</message-load-balancing>
<max-hops>1</max-hops>
<confirmation-window-size>1024</confirmation-window-size>
<static-connectors>
<connector-ref>server1-connector</connector-ref>
</static-connectors>
</cluster-connection>
</cluster-connections>
...
<address-settings>
<address-setting match="#">
<redelivery-delay>5000</redelivery-delay>
<redelivery-delay-multiplier>3</redelivery-delay-multiplier>
<max-redelivery-delay>10000</max-redelivery-delay>
<max-delivery-attempts>10</max-delivery-attempts>
<max-size-bytes>104857600</max-size-bytes>
<page-size-bytes>10485760</page-size-bytes>
<address-full-policy>PAGE</address-full-policy>
<redistribution-delay>0</redistribution-delay>
</address-setting>
</address-settings>
如何让消息重新分配工作?
谢谢!你能否指定我需要设置哪种应用程序属性以及在哪里?在客户端?在broker.xml中? – Rox
@Rox在发送的消息上设置一些应用程序属性。任何事情都应该有效。不要在没有任何应用程序属性的情况下完全发送消息。 – user7610
@ user7610:哦,我明白了!我将尝试在消息上设置一个字符串属性并查看它是否有效。结果会回到这里。 – Rox