We are using ThreadPoolExecutor in our JMS consumer and injecting it into a DefaultMessageListenerContainer. I expect this to be running concurrent threads for many messages however our logs show that the thread id won't change.Our logging shows that for different processing of messages, the thread id is always the same at 24.
This is the spring configuration in that scenario:
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer" p:connectionFactory-ref="cachedConnectionFactory" p:destination-ref="formsCRRDestination" p:messageListener-ref="formServicePojo" p:concurrentConsumers="5" p:idleTaskExecutionLimit="1" p:maxConcurrentConsumers="25" p:taskExecutor-ref="threadPoolExecutor" destroy-method="doShutdown" > <bean id="threadPoolExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" > <property name="corePoolSize" value="1"/> <property name="maxPoolSize" value="15"/> <property name="keepAliveSeconds" value="30"/> </bean>
After not injecting the threadPoolExectuor bean into the DefaultMessageListenerContainer, the messages are now being executed in different threads.
This is the resulting configuration:
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer" p:connectionFactory-ref="cachedConnectionFactory" p:destination-ref="formsCRRDestination" p:messageListener-ref="formServicePojo" p:concurrentConsumers="5" p:idleTaskExecutionLimit="1" p:maxConcurrentConsumers="25" destroy-method="doShutdown" >
I have tried reading the documentation and I don't understand why this is happening. Any explanation?
try this:
<bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <property name="corePoolSize" value="10" /> <property name="maxPoolSize" value="25" /> <property name="queueCapacity" value="30" /> </bean>
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With