From 9b6dbfa4cd33f6212815e00e2dacc86b0ef349ae Mon Sep 17 00:00:00 2001 From: yewei <17855368071@163.com> Date: Tue, 20 Sep 2022 16:43:59 +0800 Subject: [PATCH] finish adapterThreadPoolConfig modification verify --- hippo4j-config/pom.xml | 6 -- .../threadpool/ConfigModifyVerifyReqDTO.java | 1 - .../biz/threadpool/WebThreadPoolReqDTO.java | 66 +++++++++++++++++++ ...readPoolConfigModifyVerifyServiceImpl.java | 2 - ...readPoolConfigModifyVerifyServiceImpl.java | 4 +- 5 files changed, 67 insertions(+), 12 deletions(-) create mode 100644 hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/WebThreadPoolReqDTO.java diff --git a/hippo4j-config/pom.xml b/hippo4j-config/pom.xml index 3f1feb21..11c8eac7 100644 --- a/hippo4j-config/pom.xml +++ b/hippo4j-config/pom.xml @@ -73,12 +73,6 @@ ${version} - - cn.hippo4j - hippo4j-console - ${version} - - io.netty netty-all diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ConfigModifyVerifyReqDTO.java b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ConfigModifyVerifyReqDTO.java index 2b5c37fc..83863fd3 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ConfigModifyVerifyReqDTO.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/ConfigModifyVerifyReqDTO.java @@ -19,7 +19,6 @@ package cn.hippo4j.config.model.biz.threadpool; import cn.hippo4j.common.model.ThreadPoolParameterInfo; import cn.hippo4j.config.model.biz.adapter.ThreadPoolAdapterReqDTO; -import cn.hippo4j.console.model.WebThreadPoolReqDTO; import lombok.Data; /** diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/WebThreadPoolReqDTO.java b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/WebThreadPoolReqDTO.java new file mode 100644 index 00000000..5dc687f6 --- /dev/null +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/model/biz/threadpool/WebThreadPoolReqDTO.java @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package cn.hippo4j.config.model.biz.threadpool; + +import lombok.Data; + +import java.util.List; + +@Data +public class WebThreadPoolReqDTO { + + /** + * Thread-pool id + */ + private String tenantId; + + /** + * Item id + */ + private String itemId; + + /** + * thread pool instance id + */ + private String instanceId; + + /** + * Core pool size + */ + private Integer corePoolSize; + + /** + * Maximum pool size + */ + private Integer maximumPoolSize; + + /** + * Keep alive time + */ + private Integer keepAliveTime; + + /** + * weather modify all instances + */ + private Integer modifyAll; + + /** + * Client address list + */ + private List clientAddressList; +} diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AdapterThreadPoolConfigModifyVerifyServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AdapterThreadPoolConfigModifyVerifyServiceImpl.java index c25f9a8d..1ce847cc 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AdapterThreadPoolConfigModifyVerifyServiceImpl.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/AdapterThreadPoolConfigModifyVerifyServiceImpl.java @@ -17,7 +17,6 @@ package cn.hippo4j.config.service.biz.impl; - import cn.hippo4j.common.constant.ConfigModifyTypeConstants; import cn.hippo4j.common.toolkit.JSONUtil; import cn.hippo4j.config.model.biz.adapter.ThreadPoolAdapterReqDTO; @@ -29,7 +28,6 @@ import org.springframework.stereotype.Service; import static cn.hippo4j.common.constant.Constants.HTTP_EXECUTE_TIMEOUT; - @Slf4j @Service public class AdapterThreadPoolConfigModifyVerifyServiceImpl extends AbstractConfigModifyVerifyService { 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 bbe8a5bf..368a8846 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 @@ -20,20 +20,18 @@ package cn.hippo4j.config.service.biz.impl; import cn.hippo4j.common.constant.ConfigModifyTypeConstants; import cn.hippo4j.common.toolkit.JSONUtil; import cn.hippo4j.config.model.biz.threadpool.ConfigModifyVerifyReqDTO; -import cn.hippo4j.console.model.WebThreadPoolReqDTO; +import cn.hippo4j.config.model.biz.threadpool.WebThreadPoolReqDTO; import cn.hutool.core.text.StrBuilder; 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 @Service public class WebThreadPoolConfigModifyVerifyServiceImpl extends AbstractConfigModifyVerifyService { - @Override public Integer type() { return ConfigModifyTypeConstants.WEB_THREAD_POOL;