I have checked already.And another consumer that does not have
CLIENT_ACKNOWLEDGE also appears problem.
This is another consumer configuration:
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${activeMQ.brokerURL}"/>
<property name="userName" value="${activeMQ.username}"/>
<property name="password" value="${activeMQ.passwd}"/>
</bean>
<bean id="receiveQueueDestinationA"
class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="${activeMQ.queueNameA}"/>
</bean>
<bean id="receiverListenerServiceA"
class="com.xinhuanet.censor.data.service.impl.ReceiverListenerServiceImpl">
</bean>
<bean id="queueListenerA"
class="com.xinhuanet.censor.data.adapter.MessageAdapter">
<constructor-arg ref="receiverListenerServiceA"></constructor-arg>
<property name="defaultListenerMethod" value="receiveA"/>
</bean>
<bean id="queueListenerContainerA"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="receiveQueueDestinationA"/>
<property name="messageListener" ref="queueListenerA"/>
<property name="concurrentConsumers" value="8"/>
</bean>
<bean id="receiveQueueDestinationB"
class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="${activeMQ.queueNameB}"/>
</bean>
<bean id="receiverListenerServiceB"
class="com.xinhuanet.censor.data.service.impl.ReceiverListenerServiceImpl">
</bean>
<bean id="queueListenerB"
class="com.xinhuanet.censor.data.adapter.MessageAdapter">
<constructor-arg ref="receiverListenerServiceB"></constructor-arg>
<property name="defaultListenerMethod" value="receiveB"/>
</bean>
<bean id="queueListenerContainerB"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="receiveQueueDestinationB"/>
<property name="messageListener" ref="queueListenerB"/>
<property name="concurrentConsumers" value="8"/>
</bean>
There is a backlog of 1000,today.
But the queue is not blocked.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/activemq-3000-messages-can-not-be-received-tp4715396p4715694.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
