From 3e0a62b1c1726284f99d3602d5262014e66529c7 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Fri, 21 Jan 2022 23:08:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=AE=A2=E6=88=B7=E7=AB=AF?= =?UTF-8?q?=E5=9F=BA=E7=A1=80=E8=B7=AF=E5=BE=84=E8=8E=B7=E5=8F=96=E9=94=99?= =?UTF-8?q?=E8=AF=AF.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hippo4j/console/controller/ThreadPoolController.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java b/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java index d45e7c74..97f8b683 100644 --- a/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java +++ b/hippo4j-console/src/main/java/cn/hippo4j/console/controller/ThreadPoolController.java @@ -79,13 +79,18 @@ public class ThreadPoolController { .filter(each -> StringUtil.isNotBlank(each.getActive())) .collect(Collectors.toMap(InstanceInfo::getIdentify, InstanceInfo::getActive)); + Map clientBasePathMap = leases.stream() + .map(each -> each.getHolder()) + .filter(each -> StringUtil.isNotBlank(each.getClientBasePath())) + .collect(Collectors.toMap(InstanceInfo::getIdentify, InstanceInfo::getClientBasePath)); + List returnThreadPool = Lists.newArrayList(); content.forEach((key, val) -> { ThreadPoolInstanceInfo threadPoolInstanceInfo = BeanUtil.convert(val.configAllInfo, ThreadPoolInstanceInfo.class); threadPoolInstanceInfo.setClientAddress(StrUtil.subBefore(key, Constants.IDENTIFY_SLICER_SYMBOL, false)); threadPoolInstanceInfo.setActive(activeMap.get(key)); threadPoolInstanceInfo.setIdentify(key); - threadPoolInstanceInfo.setClientBasePath(holder.getClientBasePath()); + threadPoolInstanceInfo.setClientBasePath(clientBasePathMap.get(key)); returnThreadPool.add(threadPoolInstanceInfo); });