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); });