Hi,
This is my (simple) setup: A producer sends messages to a queue managed by
ActiveMQ V5.3.1. The goal is to allow concurrent MessageListener objects to
consume messages. For this the DefaultMessageListenerContainer in the Spring
Config File (see below) contains the property 'concurrentConsumers' and the
property 'brokerURL' of ActiveMQConnectionFactory has the prefetch extension
set to 0. But it seems as if only one thread is reading from the queue - as
you can see from the following log snippet
...
2010-05-04 13:17:06,752 INFO [jmsContainer-84
transport.activemq.ActiveMQMessageListenerImpl.onMessage()] called
2010-05-04 13:17:07,252 INFO [jmsContainer-84
transport.activemq.ActiveMQMessageListenerImpl.onMessage()] called
...
I would be glad if you could give me a hint on how to configure concurrent
consumers properly, thank you.
Cheerio,
Merck
Message Listener:
---
public class ActiveMQMessageListenerImpl implements MessageListener {
private static final Logger log =
Logger.getLogger(ActiveMQMessageListenerImpl.class);
public void onMessage(Message msg) {
log.info("called");
try { Thread.sleep(500); }catch(Exception e) {}
}
}
Spring Config File:
---
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:jms="http://www.springframework.org/schema/jms";
xmlns:p="http://www.springframework.org/schema/p";
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-3.0.xsd";>
<!-- A JMS connection factory for ActiveMQ -->
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL"
value="tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=0"/>
</bean>
<!-- this is the Message Driven POJO (MDP) -->
<bean id="messageListener"
class="transport.activemq.ActiveMQMessageListenerImpl" />
<!-- and this is the message listener container -->
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destinationName" value="read-q"/>
<property name="messageListener" ref="messageListener" />
<property name="concurrentConsumers" value="100"/>
</bean>
</beans>
--
View this message in context:
http://old.nabble.com/Spring---concurrent-consumers-tp28446184p28446184.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
