[GitHub] [rocketmq-spring] crzbird opened a new issue, #546: Bug in ConsumeMessageService#updateCorePoolSize" not support increase coreSize

[via GitHub]

crzbird opened a new issue, #546:
URL: https://github.com/apache/rocketmq-spring/issues/546

   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:
   The annotation RocketMQMessageListener use consumeThreadNumber as 
consumeExecutor coreSize and maximumSize,which makes method 
"ConsumeMessageService#updateCorePoolSize" not support increase coreSize.
   <img width="805" alt="image" 
src="https://user-images.githubusercontent.com/40804675/227460125-52f0a9a8-66a8-406d-9f44-3a8f54b34048.png";>
   
   <img width="824" alt="image" 
src="https://user-images.githubusercontent.com/40804675/227458257-e917b9c8-d93d-48fe-bfe0-a072167141c1.png";>
   - What did you do (The steps to reproduce)?
   1.use @RocketMQMessageListener declare a listener
   2.implement RocketMQPushConsumerLifecycleListener#prepareStart to hold 
consumer instance.
   3.call the consumer updateCorePoolSize
   corePoolSize < this.defaultMQPushConsumer.getConsumeThreadMax() is always 
false,because same value.
   - What did you expect to see?
   ConsumeMessageService#updateCorePoolSize works
   - What did you see instead?
   nothing,it does not work.
   2. Please tell us about your environment:
   JDK8 & rocketmq-spring-boot-starter:2.2.3
   3. Other information (e.g. detailed explanation, logs, related issues, 
suggestions how to fix, etc):
   I am considering reuse RocketMQMessageListener#consumeThreadMax() property 
as consumeExecutor maximumSize,and consumeThreadNumber as coreSize.Will fix it.


-- 
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: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org