diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AbstractConfigModifyVerifyService.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AbstractConfigModifyVerifyService.java index c0c5946c..f7e2a5b3 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AbstractConfigModifyVerifyService.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AbstractConfigModifyVerifyService.java @@ -67,6 +67,8 @@ public abstract class AbstractConfigModifyVerifyService implements ConfigModifyV } public void acceptModification(ConfigModifyVerifyReqDTO reqDTO) { + updateThreadPoolParameter(reqDTO); + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper() .eq(HisConfigVerifyInfo::getId, reqDTO.getId()) .set(HisConfigVerifyInfo::getVerifyStatus, VerifyEnum.VERIFY_ACCEPT.getVerifyStatus()) @@ -75,11 +77,10 @@ public abstract class AbstractConfigModifyVerifyService implements ConfigModifyV hisConfigVerifyMapper.update(null, updateWrapper); - updateThreadPoolParameter(reqDTO); } /** - * get client address according to weather modifyAll + * get client address * @param reqDTO * @return */ @@ -88,9 +89,7 @@ public abstract class AbstractConfigModifyVerifyService implements ConfigModifyV List> leases = baseInstanceRegistry.listInstance(reqDTO.getItemId()); ConditionUtil .condition(reqDTO.getModifyAll(), - () -> { - leases.forEach(lease -> clientAddressList.add(lease.getHolder().getCallBackUrl())); - }, + () -> leases.forEach(lease -> clientAddressList.add(lease.getHolder().getCallBackUrl())), () -> clientAddressList.add( leases.stream() .filter(lease -> lease.getHolder().getIdentify().equals(reqDTO.getIdentify())).findAny().orElseThrow(() -> new RuntimeException("线程池实例并不存在")).getHolder() diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/WebThreadPoolConfigModifyVerifyServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/WebThreadPoolConfigModifyVerifyServiceImpl.java index 4e4d8ab9..ab0598d3 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/WebThreadPoolConfigModifyVerifyServiceImpl.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/WebThreadPoolConfigModifyVerifyServiceImpl.java @@ -25,7 +25,6 @@ import cn.hutool.http.HttpUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; - import static cn.hippo4j.common.constant.Constants.HTTP_EXECUTE_TIMEOUT; @Slf4j