You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/07/16 02:01:45 UTC
[rocketmq] branch develop updated: delete the unuse code
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 04c7354 delete the unuse code
new 36333ce Merge pull request #3157 from yglovewms/yeyi
04c7354 is described below
commit 04c7354149793f5da0dc1a94c3ef58bd1137f688
Author: Steven Liang <16...@qq.com>
AuthorDate: Fri Jul 16 09:50:42 2021 +0800
delete the unuse code
---
.../ConsumeMessageConcurrentlyService.java | 24 ++--------------------
1 file changed, 2 insertions(+), 22 deletions(-)
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 925e525..537dbee 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