codersfarm opened a new issue #3470: URL: https://github.com/apache/rocketmq/issues/3470
In branch develop,MQClientInstance.this.adjustThreadPool(); in MQClientInstance class. call the method adjustThreadPool(), next call mehod DefaultMQPushConsumerImpl.adjustThreadPool(). But the implementation class ConsumeMessageConcurrentlyService's method decCorePoolSize and incCorePoolSize is commented，the other implementation class ConsumeMessageOrderlyService's method decCorePoolSize and incCorePoolSize is empty.   -- 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]
