diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java index 925e5258b52df85d99dca5071726e3fb7daf56ce..537dbee832d59df982120950a770caf5d697ba46 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java @@ -110,32 +110,12 @@ public class ConsumeMessageConcurrentlyService implements ConsumeMessageService @Override public void incCorePoolSize() { - // long corePoolSize = this.consumeExecutor.getCorePoolSize(); - // if (corePoolSize < this.defaultMQPushConsumer.getConsumeThreadMax()) - // { - // this.consumeExecutor.setCorePoolSize(this.consumeExecutor.getCorePoolSize() - // + 1); - // } - // log.info("incCorePoolSize Concurrently from {} to {}, ConsumerGroup: - // {}", - // corePoolSize, - // this.consumeExecutor.getCorePoolSize(), - // this.consumerGroup); + } @Override public void decCorePoolSize() { - // long corePoolSize = this.consumeExecutor.getCorePoolSize(); - // if (corePoolSize > this.defaultMQPushConsumer.getConsumeThreadMin()) - // { - // this.consumeExecutor.setCorePoolSize(this.consumeExecutor.getCorePoolSize() - // - 1); - // } - // log.info("decCorePoolSize Concurrently from {} to {}, ConsumerGroup: - // {}", - // corePoolSize, - // this.consumeExecutor.getCorePoolSize(), - // this.consumerGroup); + } @Override