From d0d7a27194d214ff232facd1e53e2fc23010fcff Mon Sep 17 00:00:00 2001
From: "chen.ma" <machencoding@163.com>
Date: Tue, 9 Aug 2022 21:50:02 +0800
Subject: [PATCH] Remove blocking queue type from thread pool changelog

---
 .../cn/hippo4j/common/constant/ChangeThreadPoolConstants.java | 1 -
 .../springboot/starter/refresher/event/ExecutorsListener.java | 1 -
 .../starter/core/ServerThreadPoolDynamicRefresh.java          | 4 +---
 3 files changed, 1 insertion(+), 5 deletions(-)

diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/constant/ChangeThreadPoolConstants.java b/hippo4j-common/src/main/java/cn/hippo4j/common/constant/ChangeThreadPoolConstants.java
index 959d4af1..3e7a7773 100644
--- a/hippo4j-common/src/main/java/cn/hippo4j/common/constant/ChangeThreadPoolConstants.java
+++ b/hippo4j-common/src/main/java/cn/hippo4j/common/constant/ChangeThreadPoolConstants.java
@@ -25,7 +25,6 @@ public class ChangeThreadPoolConstants {
     public static final String CHANGE_THREAD_POOL_TEXT = "Dynamic thread pool change parameter: [{}]" +
             "\n    corePoolSize: [{}]" +
             "\n    maximumPoolSize: [{}]" +
-            "\n    blockingQueueType: [{}]" +
             "\n    capacity: [{}]" +
             "\n    keepAliveTime: [{}]" +
             "\n    executeTimeOut: [{}]" +
diff --git a/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java b/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java
index 7b27ca13..a0db5d50 100644
--- a/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java
+++ b/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/refresher/event/ExecutorsListener.java
@@ -89,7 +89,6 @@ public class ExecutorsListener implements ApplicationListener<Hippo4jCoreDynamic
                     threadPoolId,
                     String.format(CHANGE_DELIMITER, beforeProperties.getCorePoolSize(), properties.getCorePoolSize()),
                     String.format(CHANGE_DELIMITER, beforeProperties.getMaximumPoolSize(), properties.getMaximumPoolSize()),
-                    String.format(CHANGE_DELIMITER, beforeProperties.getBlockingQueue(), properties.getBlockingQueue()),
                     String.format(CHANGE_DELIMITER, beforeProperties.getQueueCapacity(), properties.getQueueCapacity()),
                     String.format(CHANGE_DELIMITER, beforeProperties.getKeepAliveTime(), properties.getKeepAliveTime()),
                     String.format(CHANGE_DELIMITER, beforeProperties.getExecuteTimeOut(), properties.getExecuteTimeOut()),
diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java
index 77978fb2..5af1c447 100644
--- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java
+++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java
@@ -107,9 +107,7 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh
                 threadPoolId,
                 String.format(CHANGE_DELIMITER, originalCoreSize, afterExecutor.getCorePoolSize()),
                 String.format(CHANGE_DELIMITER, originalMaximumPoolSize, afterExecutor.getMaximumPoolSize()),
-                String.format(CHANGE_DELIMITER, originalQuery, QueueTypeEnum.getBlockingQueueNameByType(parameter.getQueueType())),
-                String.format(CHANGE_DELIMITER, originalCapacity,
-                        (afterExecutor.getQueue().remainingCapacity() + afterExecutor.getQueue().size())),
+                String.format(CHANGE_DELIMITER, originalCapacity, (afterExecutor.getQueue().remainingCapacity() + afterExecutor.getQueue().size())),
                 String.format(CHANGE_DELIMITER, originalKeepAliveTime, afterExecutor.getKeepAliveTime(TimeUnit.SECONDS)),
                 String.format(CHANGE_DELIMITER, originalExecuteTimeOut, originalExecuteTimeOut),
                 String.format(CHANGE_DELIMITER, originalRejected, RejectedTypeEnum.getRejectedNameByType(parameter.getRejectedType())),