activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chester_Zheng <chester_zh...@sina.com>
Subject Re: Re: o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers has dropped below concurrentConsumers limit, probably due to tasks having been rejected. Check your thread pool configuration! Automatic recovery to be triggered by remaining consumers.
Date Fri, 09 Jun 2017 09:30:18 GMT
hi, Tim

Thanks for ur suggestion.



chester_zheng@sina.com
 
From: Tim Bain [via ActiveMQ]
Date: 2017-06-07 20:50
To: Chester_Zheng
Subject: Re: o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers
has dropped below concurrentConsumers limit, probably due to tasks having been rejected. Check
your thread pool configuration! Automatic recovery to be triggered by remaining consumers.
Does your thread pool allow you to create up to 500 threads? 

This question really doesn't have anything to do with ActiveMQ, so although 
you might get an answer here, I'd strongly suggest that you post it on the 
Spring mailing list and on StackOverflow (since lots of people who know 
Spring hang out there). 

Tim 

On Jun 7, 2017 3:19 AM, "Chester_Zheng" <[hidden email]> wrote: 

> Hi, AllI met a problem. I used the "DefaultMessageListenerContainer" to 
> increase the consumer count, but when the app run awhile, the log shows 
> that 
> "o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled 
> consumers has dropped below concurrentConsumers limit, probably due to 
> tasks 
> having been rejected. Check your thread pool configuration! Automatic 
> recovery to be triggered by remaining consumers."The XML configuration that 
> I use a single point. No any cluster.The Java code config is 
> following:DefaultMessageListenerContainer defaultMessageListenerContainer 
> = 
> new DefaultMessageListenerContainer(); 
> defaultMessageListenerContainer.setPubSubDomain(true); 
> defaultMessageListenerContainer.setDestination(adminQueue); 
> defaultMessageListenerContainer.setConnectionFactory(connectionFactory); 
> defaultMessageListenerContainer.setPubSubNoLocal(false); 
> defaultMessageListenerContainer.setMessageListener(this); 
> defaultMessageListenerContainer.setSessionAcknowledgeMode( 
> Session.AUTO_ACKNOWLEDGE); 
> defaultMessageListenerContainer.setIdleConsumerLimit(10); 
> defaultMessageListenerContainer.setIdleTaskExecutionLimit(100); 
> defaultMessageListenerContainer.initialize(); 
> defaultMessageListenerContainer.setMaxMessagesPerTask(10); 
> defaultMessageListenerContainer.setConcurrentConsumers(100); 
> defaultMessageListenerContainer.setMaxConcurrentConsumers(500); 
> defaultMessageListenerContainer.start();And for increasing producing and 
> consuming, I made more than 1 message queue. I don't think that making more 
> queues can lead to this problem.How could I solve this problem?Please, Help 
> me.Thanks!!! 
> 
> 
> 
> -- 
> View this message in context: http://activemq.2283324.n4. 
> nabble.com/o-s-jms-listener-DefaultMessageListenerContaine 
> r-Number-of-scheduled-consumers-has-dropped-below-con-tp4727138.html 
> Sent from the ActiveMQ - User mailing list archive at Nabble.com. 




If you reply to this email, your message will be added to the discussion below:
http://activemq.2283324.n4.nabble.com/o-s-jms-listener-DefaultMessageListenerContainer-Number-of-scheduled-consumers-has-dropped-below-con-tp4727138p4727150.html

To unsubscribe from o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers
has dropped below concurrentConsumers limit, probably due to tasks having been rejected. Check
your thread pool configuration! Automatic recovery to be triggered by remaining consumers.,
click here.
NAML 




--
View this message in context: http://activemq.2283324.n4.nabble.com/o-s-jms-listener-DefaultMessageListenerContainer-Number-of-scheduled-consumers-has-dropped-below-con-tp4727138p4727269.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message