From be761e12a002858ca67f7fb5a6df05ac853f7637 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=90=8C=E5=AD=A6?= Date: Wed, 18 May 2022 21:49:36 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90delete=E3=80=91=E6=97=A0=E7=94=A8?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../rocketmq/SpringCloudStreamRocketMQThreadPoolAdapter.java | 1 - 1 file changed, 1 deletion(-) 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 455d6596..9f6fb24b 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 @@ -63,7 +63,6 @@ public class SpringCloudStreamRocketMQThreadPoolAdapter implements ThreadPoolAda ThreadPoolAdapterState result = new ThreadPoolAdapterState(); ThreadPoolExecutor rocketMQConsumeExecutor = ROCKET_MQ_SPRING_CLOUD_STREAM_CONSUME_EXECUTOR.get(identify); if (rocketMQConsumeExecutor != null) { - result.setThreadPoolKey(mark()); result.setThreadPoolKey(identify); result.setCoreSize(rocketMQConsumeExecutor.getCorePoolSize()); result.setMaximumSize(rocketMQConsumeExecutor.getMaximumPoolSize());