Hi, Can you help to understand why my consumers stop after few msg !? I develop a webapp with an embed jms broker and a download queue (activemq + spring2.5 ). After few msg the number of consumers increase to reach the maximun number 10 and consumer stop. I can send msg in queue : the queue size increase but they are not consume and no exception is threw :-(
Here my application context config : <!-- lets create an embedded ActiveMQ Broker --> <amq:broker useJmx="true" persistent="true"> <amq:persistenceAdapter> <amq:amqPersistenceAdapter directory="/tmp/activemq-data" /> </amq:persistenceAdapter> <amq:transportConnectors> <amq:transportConnector uri="tcp://localhost:0" /> </amq:transportConnectors> </amq:broker> <amq:commandAgent></amq:commandAgent> <!-- ActiveMQ destinations to use --> <!-- Queue of message from the encoder components --> <amq:queue id="fromEncoderQueue" physicalName="fromEncoderQueue" /> <!-- Queue fo message to the encoder components --> <amq:queue id="toEncoderQueue" physicalName="toEncoderQueue" /> <!-- JMS ConnectionFactory to use, configuring the embedded broker using XML --> <amq:connectionFactory id="jmsFactory" brokerURL="vm://localhost?jms.prefetchPolicy.all=0" /> <!-- Define the Spring JMS template --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- property name="connectionFactory" ref="connectionFactory"/ --> <property name="connectionFactory"> <!-- lets wrap in a pool to avoid creating a connection per send --> <bean class="org.springframework.jms.connection.SingleConnectionFactory"> <property name="targetConnectionFactory"> <ref local="jmsFactory" /> </property> </bean> </property> </bean> <!-- A producer to send msg to the queue.encoder.responses --> <bean id="msgFromEncoderProducer" class="com.cellfish.jms.JMSProducer"> <property name="template" ref="jmsTemplate" /> <property name="destination" ref="fromEncoderQueue" /> </bean> <!-- A producer to send msg to the queue.encoder.requests --> <bean id="msgToEncoderProducer" name="" class="com.cellfish.jms.JMSProducer"> <property name="template" ref="jmsTemplate" /> <property name="destination" ref="toEncoderQueue" /> </bean> <!-- this is the Message Driven POJO (MDP) --> <bean id="msgFromEncoderListener" class="com.cellfish.jms.MsgFromEncoderListener" /> <!-- this is the Message Driven POJO (MDP) --> <bean id="msgToEncoderListener" class="com.cellfish.jms.MsgToEncoderListener" /> <jms:listener-container connection-factory="jmsFactory" concurrency="10"> <jms:listener destination="toEncoderQueue" ref="msgToEncoderListener" /> <jms:listener destination="fromEncoderQueue" ref="msgFromEncoderListener" /> </jms:listener-container> -- View this message in context: http://www.nabble.com/JMS-Consumer-count-increase-and-no-msg-are-consume-tp25684115p25684115.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.