我正在使用ActiveMQ 5.7.0並嘗試實施重新傳遞策略。我有兩個隊列需要設置重新送達政策。但是在測試中,它不適用於我的政策。不是按照下面的配置,而是在1秒間隔內重試7次(不是我指定的)。ActiveMQ 5.7.0 redeliveryPolicy未應用
<!-- ActiveMQ destinations to use -->
<amq:queue id="destinationOne" physicalName="${activemq.one.queuename}">
<amq:properties>
<amq:redeliveryPolicy destination="One.DLQ" maximumRedeliveries="5" initialRedeliveryDelay="300000" useExponentialBackOff="true" backOffMultiplier="2" maximumRedeliveryDelay="3600000"/>
</amq:properties>
</amq:queue>
<amq:queue id="destinationTwo" physicalName="${activemq.two.queuename}">
<amq:properties>
<amq:redeliveryPolicy destination="Two.DLQ" maximumRedeliveries="5" initialRedeliveryDelay="300000" useExponentialBackOff="true" backOffMultiplier="2" maximumRedeliveryDelay="3600000"/>
</amq:properties>
</amq:queue>
我有兩個聽衆定義,它們如下應用隊列:
<bean id="oneMessageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<property name="destination" ref="destinationOne"/>
<property name="messageListener" ref="jmsOneListener" />
<property name="autoStartup" value="false" />
<property name="sessionTransacted" value="true"/>
<property name="concurrentConsumers" value="2" />
</bean>
<bean id="twoMessageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<property name="destination" ref="destinationTwo"/>
<property name="messageListener" ref="jmsTwoListener" />
<property name="autoStartup" value="false" />
<property name="sessionTransacted" value="true"/>
<property name="concurrentConsumers" value="2" />
</bean>
是的,謝謝你填寫的細節。 –