From 1db589695339add069be227b1f6d75daed6e78f9 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Wed, 7 Jul 2021 17:45:38 +0800 Subject: [PATCH] =?UTF-8?q?style:=20=E4=BB=A3=E7=A0=81=E6=A0=BC=E5=BC=8F?= =?UTF-8?q?=E4=BC=98=E5=8C=96.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../threadpool/starter/listener/ThreadPoolRunListener.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/listener/ThreadPoolRunListener.java b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/listener/ThreadPoolRunListener.java index 40d3e04f..6b433bbd 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/listener/ThreadPoolRunListener.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/listener/ThreadPoolRunListener.java @@ -43,9 +43,7 @@ public class ThreadPoolRunListener { public void run() { DynamicThreadPoolBanner.printBanner(properties.isBanner()); - Map executorMap = - ApplicationContextHolder.getBeansOfType(DynamicThreadPoolWrap.class); - + Map executorMap = ApplicationContextHolder.getBeansOfType(DynamicThreadPoolWrap.class); executorMap.forEach((key, val) -> { Map queryStrMap = new HashMap(3); queryStrMap.put("tpId", val.getTpId()); @@ -55,6 +53,7 @@ public class ThreadPoolRunListener { PoolParameterInfo ppi = new PoolParameterInfo(); HttpAgent httpAgent = new ServerHttpAgent(properties); Result result = null; + try { result = httpAgent.httpGet(Constants.CONFIG_CONTROLLER_PATH, null, queryStrMap, 3000L); if (result.isSuccess() && (ppi = JSON.toJavaObject((JSON) result.getData(), PoolParameterInfo.class)) != null) {