joewee opened a new issue #429: URL: https://github.com/apache/rocketmq-spring/issues/429
The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? @RocketMQMessageListener( topic = "topic1", consumerGroup = "consumer1", consumeThreadMax = 32 ) public class DemoConsumer implements RocketMQListener<String> { } - What did you expect to see? The max number of consumer threads can be reached to 32 - What did you see instead? The number of consumer threads can only reach 20 2. Please tell us about your environment: 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): Because ThreadPoolExecutor in implementation of ConsumeMessageService interface uses LinkedBlockingQueue with default capacity bound (Integer.MAX_VALUE) ,the threads will only increase when the LinkedBlockingQueue is full, so 'consumeThreadMax' is not works well as expected . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
