Message Queue get stuck with 2 consumers connected to it

[Mykola <mp...@gmail.com>]

Hi all
I'm using network of brokers config with 2 brokers
After some time one of the queues on one broker stopped dispatching messages
to its 2 consumers, log files contained no errors and any kind of strange
behavior, 3 other queues on the same broker were just fine

my config file for brokers is as simple as following

<beans>
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
<broker brokerName="sonoportal-amq" useJmx="true"
xmlns="http://activemq.org/config/1.0"
dataDirectory="${activemq.base}/data">
<managementContext>
        <managementContext connectorPort="1100"
jmxDomainName="org.apache.activemq" />
</managementContext>
<transportConnectors>
        <transportConnector name="openwire"
uri="tcp://amq01-qa.dc.sonopia.com:61616" />
</transportConnectors>
<networkConnectors>
        <networkConnector uri="static:(tcp://amq02-qa.dc.sonopia.com:61616)"
networkTTL='5' dynamicOnly='true'/>
</networkConnectors>
</broker>
</beans>

And symmetric one for second broker

Listeners are configured with Spring and has a following configuration

    <bean id="mailJmsListenerContainer"
class="org.springframework.jms.listener.SimpleMessageListenerContainer">
        <property name="concurrentConsumers" value="2" />
        <property name="connectionFactory" ref="jmsConnectionFactory" />
        <property name="destination" ref="mailJmsDestination" />
        <property name="messageListener">
        	 <ref bean="mailJmsListener"/>
        </property>
        <property name="sessionTransacted" value="true"></property>
    </bean>

Connection Factory is 

	<bean id="jmsConnectionFactory"
		class="org.apache.activemq.pool.PooledConnectionFactory"
		init-method="start" destroy-method="stop" depends-on="jmsBroker">
		<property name="connectionFactory">
			<bean
				class="org.apache.activemq.ActiveMQConnectionFactory">
				<property name="brokerURL"			
value="failover:(tcp://amq01-qa.dc.sonopia.com:61616,tcp://amq02-qa.dc.sonopia.com:61616)"
/>
				<property name="redeliveryPolicy">
					<bean class="org.apache.activemq.RedeliveryPolicy">
						<property name="backOffMultiplier" value="3"/>
						<property name="useExponentialBackOff" value="true"/>
						<property name="maximumRedeliveries" value="11"></property>
						<property name="initialRedeliveryDelay" value="2000"></property>
					</bean>
				</property>
			</bean>
		</property>
	</bean>
	<!-- JMS queue for sending Mail -->
	<bean id="mailJmsDestination"
		class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg>
			<value>QUEUE.MAIL</value>
		</constructor-arg>
	</bean>


I monitored the Brocker with JMX and get the increasing queue size. What is
the problem here? Why messages get stuck in the Queue.
I'm using 4.1.1 version with Spring 2.0.5

Interesting thing that after restarting of the server, messages get
consumed, so I assume the problem might be in listeners. One more
interesting bug is that after they get consumed QueueSize attribute became
negative, how this can be possible, I assume that it get calculated as
EnqueueCount - DequeueCount, which is not correct if broker get restarted

Thanks in advance for any help
-- 
View this message in context: http://www.nabble.com/Message-Queue-get-stuck-with-2-consumers-connected-to-it-tf4516386s2354.html#a12882306
Sent from the ActiveMQ - User mailing list archive at Nabble.com.