Hi,
I'm having a problem with message redelivery (ActiveMQ version is 5.5). It
seems messages are redelivered from the broker to the consumer several
times. The session is not transacted and the acknowledgement mode is auto.
Besides I cannot see any exception thrown by the application.
Our consumer is a a simple MessageListener wrapped in Spring's
DefaultMessageListenerContainer with the following configuration:
<bean id="listenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="messageListener" ref="listener" />
<property name="connectionFactory" ref="jmsConnectionFactory" />
<property name="destination" ref="userNotificationMq" />
</bean>
<bean id="userNotificationMq"
class="org.apache.activemq.command.ActiveMQQueue">
<property name="physicalName" value="usernotification" />
</bean>
Our jmsConnectionFactory looks like this:
<bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="vm://localhost?broker.persistent=true"
/>
<property name="redeliveryPolicy">
<bean class="org.apache.activemq.RedeliveryPolicy">
<property name="maximumRedeliveries"
value="144" />
<property name="redeliveryDelay"
value="1800000" />
</bean>
</property>
</bean>
The redeliverypolicy defined is for a different MessageListener which
listens to a different destination.
The brokerURL is the following:
failover:(tcp://BROKER_A_HOSTNAME:BROKER_A_PORT,tcp://BROKER_B_HOSTNAME:BROKER_B_PORT)?timeout=5000&randomize=false
We are using network of brokers with the following configuration:
Broker A
<networkConnectors>
<networkConnector
uri="static:(tcp://BROKER_B_HOSTNAME:BROKER_B_PORT)"/>
</networkConnectors>
Broker B
<networkConnectors>
<networkConnector
uri="static:(tcp://BROKER_A_HOSTNAME:BROKER_A_PORT)"/>
</networkConnectors>
Any help would be appreciated
--
View this message in context:
http://activemq.2283324.n4.nabble.com/redelivery-from-a-queue-tp3904212p3904212.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
