From fa5075a7e9bf202fd615f8121a912190a13c27b2 Mon Sep 17 00:00:00 2001
From: "chen.ma" <machencoding@163.com>
Date: Fri, 20 May 2022 19:22:21 +0800
Subject: [PATCH] Change the naming of thread pool adaptation parameters

---
 .../hippo4j/adapter/base/ThreadPoolAdapterParameter.java  | 8 ++++----
 .../cn/hippo4j/adapter/dubbo/DubboThreadPoolAdapter.java  | 4 ++--
 .../SpringCloudStreamRocketMQThreadPoolAdapter.java       | 4 ++--
 .../starter/controller/ThreadPoolAdapterController.java   | 2 +-
 4 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterParameter.java b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterParameter.java
index c4e8b31c..c68129eb 100644
--- a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterParameter.java
+++ b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterParameter.java
@@ -36,12 +36,12 @@ public class ThreadPoolAdapterParameter {
     private String threadPoolKey;
 
     /**
-     * Core size
+     * Core pool size
      */
-    private Integer coreSize;
+    private Integer corePoolSize;
 
     /**
-     * Maximum size
+     * Maximum pool size
      */
-    private Integer maximumSize;
+    private Integer maximumPoolSize;
 }
diff --git a/hippo4j-adapter/hippo4j-adapter-dubbo/src/main/java/cn/hippo4j/adapter/dubbo/DubboThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-dubbo/src/main/java/cn/hippo4j/adapter/dubbo/DubboThreadPoolAdapter.java
index 95c4b94f..a8c1d73a 100644
--- a/hippo4j-adapter/hippo4j-adapter-dubbo/src/main/java/cn/hippo4j/adapter/dubbo/DubboThreadPoolAdapter.java
+++ b/hippo4j-adapter/hippo4j-adapter-dubbo/src/main/java/cn/hippo4j/adapter/dubbo/DubboThreadPoolAdapter.java
@@ -77,8 +77,8 @@ public class DubboThreadPoolAdapter implements ThreadPoolAdapter, ApplicationLis
         if (tp == null) {
             return false;
         }
-        tp.setCorePoolSize(threadPoolAdapterParameter.getCoreSize());
-        tp.setMaximumPoolSize(threadPoolAdapterParameter.getMaximumSize());
+        tp.setCorePoolSize(threadPoolAdapterParameter.getCorePoolSize());
+        tp.setMaximumPoolSize(threadPoolAdapterParameter.getMaximumPoolSize());
         return true;
     }
 
diff --git a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQThreadPoolAdapter.java
index 9f6fb24b..14dc3db2 100644
--- a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQThreadPoolAdapter.java
+++ b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQThreadPoolAdapter.java
@@ -87,8 +87,8 @@ public class SpringCloudStreamRocketMQThreadPoolAdapter implements ThreadPoolAda
         if (rocketMQConsumeExecutor != null) {
             int originalCoreSize = rocketMQConsumeExecutor.getCorePoolSize();
             int originalMaximumPoolSize = rocketMQConsumeExecutor.getMaximumPoolSize();
-            rocketMQConsumeExecutor.setCorePoolSize(threadPoolAdapterParameter.getCoreSize());
-            rocketMQConsumeExecutor.setMaximumPoolSize(threadPoolAdapterParameter.getMaximumSize());
+            rocketMQConsumeExecutor.setCorePoolSize(threadPoolAdapterParameter.getCorePoolSize());
+            rocketMQConsumeExecutor.setMaximumPoolSize(threadPoolAdapterParameter.getMaximumPoolSize());
             log.info("[{}] RocketMQ consumption thread pool parameter change. coreSize :: {}, maximumSize :: {}",
                     threadPoolKey,
                     String.format(CHANGE_DELIMITER, originalCoreSize, rocketMQConsumeExecutor.getCorePoolSize()),
diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/controller/ThreadPoolAdapterController.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/controller/ThreadPoolAdapterController.java
index a232089a..1ca73e1a 100644
--- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/controller/ThreadPoolAdapterController.java
+++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/controller/ThreadPoolAdapterController.java
@@ -67,7 +67,7 @@ public class ThreadPoolAdapterController {
     @PostMapping("/adapter/thread-pool/update")
     public Result<Void> updateAdapterThreadPool(@RequestBody ThreadPoolAdapterParameter requestParameter) {
         log.info("[{}] Change third-party thread pool data. key: {}, coreSize: {}, maximumSize: {}",
-                requestParameter.getMark(), requestParameter.getThreadPoolKey(), requestParameter.getCoreSize(), requestParameter.getMaximumSize());
+                requestParameter.getMark(), requestParameter.getThreadPoolKey(), requestParameter.getCorePoolSize(), requestParameter.getMaximumPoolSize());
         ThreadPoolAdapter threadPoolAdapter = THREAD_POOL_ADAPTER_BEAN_CONTAINER.get(requestParameter.getMark());
         Optional.ofNullable(threadPoolAdapter).ifPresent(each -> each.updateThreadPool(requestParameter));
         return Results.success();