shepherdviolet opened a new issue #184: The config 'consumeThreadMax' is useless in annotation @RocketMQMessageListener URL: https://github.com/apache/rocketmq-spring/issues/184 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)? ```text @RocketMQMessageListener( topic = "...", consumerGroup = "...", consumeThreadMax = 30 ) public class RocketMqStarterSimpleConsumer implements RocketMQListener<String> { } ``` - What did you expect to see? ```text The consumer threads can up to 30 ``` - What did you see instead? ```text The number of consumer threads can only reach 20 ``` 2. Please tell us about your environment: ```text -- ``` 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): ```text In the source code 'ConsumeMessageConcurrentlyService', we can see that consumeThreadMax is useless ``` ```text public class ConsumeMessageConcurrentlyService implements ConsumeMessageService { ...... public ConsumeMessageConcurrentlyService(DefaultMQPushConsumerImpl defaultMQPushConsumerImpl, MessageListenerConcurrently messageListener) { ...... this.consumeRequestQueue = new LinkedBlockingQueue<Runnable>(); this.consumeExecutor = new ThreadPoolExecutor( this.defaultMQPushConsumer.getConsumeThreadMin(), this.defaultMQPushConsumer.getConsumeThreadMax(), 1000 * 60, TimeUnit.MILLISECONDS, this.consumeRequestQueue, new ThreadFactoryImpl("ConsumeMessageThread_")); ...... } ```
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
