pull/776/head
airoger 3 years ago
parent b603d54951
commit 0092e78629

@ -64,11 +64,6 @@ public class ConfigModifyVerifyReqDTO {
*/
private Boolean modifyAll;
/**
* Client address list
*/
private List<String> clientAddressList;
/**
* weather accept config modification
*/

@ -76,8 +76,6 @@ public abstract class AbstractConfigModifyVerifyService implements ConfigModifyV
hisConfigVerifyMapper.update(null, updateWrapper);
reqDTO.setClientAddressList(getClientAddress(reqDTO));
updateThreadPoolParameter(reqDTO);
}
@ -86,7 +84,7 @@ public abstract class AbstractConfigModifyVerifyService implements ConfigModifyV
* @param reqDTO
* @return
*/
private List<String> getClientAddress(ConfigModifyVerifyReqDTO reqDTO) {
protected List<String> getClientAddress(ConfigModifyVerifyReqDTO reqDTO) {
List<String> clientAddressList = new ArrayList<>();
ConditionUtil
.condition(reqDTO.getModifyAll(),

@ -39,7 +39,7 @@ public class AdapterThreadPoolConfigModifyVerifyServiceImpl extends AbstractConf
@Override
protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) {
for (String each : reqDTO.getClientAddressList()) {
for (String each : getClientAddress(reqDTO)) {
String urlString = StrBuilder.create("http://", each, "/adapter/thread-pool/update").toString();
HttpUtil.post(urlString, JSONUtil.toJSONString(reqDTO), HTTP_EXECUTE_TIMEOUT);
}

@ -42,6 +42,8 @@ public class ThreadPoolInstanceConfigModifyVerifyServiceImpl extends AbstractCon
@Override
protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) {
ConfigAllInfo config = BeanUtil.convert(reqDTO, ConfigAllInfo.class);
config.setCoreSize(reqDTO.getCorePoolSize());
config.setMaxSize(reqDTO.getMaximumPoolSize());
configService.insertOrUpdate(reqDTO.getInstanceId(), true, config);
}

@ -38,7 +38,7 @@ public class WebThreadPoolConfigModifyVerifyServiceImpl extends AbstractConfigMo
@Override
protected void updateThreadPoolParameter(ConfigModifyVerifyReqDTO reqDTO) {
for (String each : reqDTO.getClientAddressList()) {
for (String each : getClientAddress(reqDTO)) {
String urlString = StrBuilder.create("http://", each, "/web/update/pool").toString();
HttpUtil.post(urlString, JSONUtil.toJSONString(reqDTO), HTTP_EXECUTE_TIMEOUT);
}

Loading…
Cancel
Save