activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From naga007 <NSo...@gmail.com>
Subject Re: Redelivery policy not honored
Date Wed, 11 Jul 2007 17:11:12 GMT

Use CACHE_CONSUMER in Spring Message listener container, this will not create
session and consumer everytime its polls.





Adam Lewandowski wrote:
> 
> At what level does the redelivery policy get applied? I've got a 
> transactional consumer (Spring MDP) that is performing a rollback and I 
> am expecting the message to be redelivered a maximum number of times as 
> specified on the connection factory's redelivery policy. After the 
> maximum retry attempts, I'm expecting to see the message sent to the 
> dead letter queue as specified in the broker's destination policy map.
> Instead, the message gets delivered over and over again, with an 
> increasing value for the JMSXDeliveryCount message property and never 
> gets placed on the dead letter queue. It looks as if the redelivery 
> policy isn't being honored.
> The only place I could find in the code where the redelivery policy is 
> applied is at the MessageConsumer level (ActiveMQMessageConsumer). This 
> doesn't make sense to me since a different consumers could get the 
> message on repeated delivery attempts, correct? Spring's message 
> listener framework seems to confirm this as it uses a polling model, 
> creating a new MessageConsumer and Session once per second 
> (AbstractPollingMessageListenerContainer). Does AMQ expect that the same 
> MessageConsumer will be used for message redelivery in a transactional 
> setting?
> 
> Configuration:
> Connection Factory:
>     <bean id="jmsConnectionFactory"
>         class="org.apache.activemq.ActiveMQConnectionFactory">
>         <property name="brokerURL" value="vm://broker" />
>         <property name="redeliveryPolicy">
>             <bean class="org.apache.activemq.RedeliveryPolicy">
>                 <property name="maximumRedeliveries" value="2" />
>             </bean>
>         </property>
>     </bean>
> 
> Broker:
>     <broker brokerName="broker" persistent="true" useJmx="false"
>         start="true" xmlns="http://activemq.org/config/1.0">
>         <destinationPolicy>
>             <policyMap>
>                  <policyEntries>
>                      <policyEntry queue="EventQueue">
>                         <deadLetterStrategy>
>                             <individualDeadLetterStrategy 
> queuePrefix="DEAD" />
>                         </deadLetterStrategy>
>                      </policyEntry>
>                  </policyEntries>               
>             </policyMap>
>         </destinationPolicy>
>         <transportConnectors>
>             <transportConnector uri="vm://broker" />
>         </transportConnectors>
>     </broker>
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Redelivery-policy-not-honored-tf4058148s2354.html#a11544578
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message