ActiveMQ(20):Consumer高级特性之重新投递(activemq服务实现)
一、简介
参考ActiveMQ(20):Consumer高级特性之重新投递(Redelivery Policy)
注意:由于在某些情况下,spring与此mq整合时会产生maximumRedeliveries与initialRedeliveryDelay冲突,此时采用如下方法即可解决
二、操作
1、配置activemq/conf/activemq.xml文件的broker中:
<plugins> <redeliveryPlugin fallbackToDeadLetter="true" sendToDlqIfMaxRetriesExceeded="true"> <redeliveryPolicyMap> <redeliveryPolicyMap> <redeliveryPolicyEntries> <redeliveryPolicy useExponentialBackOff="true" backOffMultiplier="2" queue=">" maximumRedeliveries="3" initialRedeliveryDelay="10000" /> </redeliveryPolicyEntries> </redeliveryPolicyMap> </redeliveryPolicyMap> </redeliveryPlugin> </plugins>
2、配置连接url,此处重置maximumRedeliveries为0,原因前面文章又讲,此处不再说明
#集群容错 active.mq.url=failover:(tcp://192.168.175.13:61616)??jms.prefetchPolicy.all=100&jms.redeliveryPolicy.maximumRedeliveries=0 #单机 #active.mq.url=tcp://192.168.175.13:61616?jms.prefetchPolicy.all=100&jms.redeliveryPolicy.maximumRedeliveries=0
测试效果:
转载于:https://blog.51cto.com/1754966750/1928694