refactord to resolve the flaky

pull/1373/head
Kazi Akib Javed 2 years ago
parent 037b388921
commit db431a343b

@ -19,7 +19,6 @@ package cn.hippo4j.common.toolkit;
import cn.hippo4j.common.constant.Constants; import cn.hippo4j.common.constant.Constants;
import cn.hippo4j.common.model.ThreadPoolParameter; import cn.hippo4j.common.model.ThreadPoolParameter;
import cn.hippo4j.common.model.ThreadPoolParameterInfo;
/** /**
* Content util. * Content util.
@ -33,22 +32,13 @@ public class ContentUtil {
* @return dynamic thread-pool content str * @return dynamic thread-pool content str
*/ */
public static String getPoolContent(ThreadPoolParameter parameter) { public static String getPoolContent(ThreadPoolParameter parameter) {
ThreadPoolParameterInfo threadPoolParameterInfo = new ThreadPoolParameterInfo(); String getPoolContent = String.format("{\"tenantId\":\"%s\",\"itemId\":\"%s\",\"tpId\":" +
threadPoolParameterInfo.setTenantId(parameter.getTenantId()) "\"%s\",\"queueType\":%d,\"capacity\":%d,\"keepAliveTime\":%d,\"rejectedType\":%d,\"isAlarm\"" +
.setItemId(parameter.getItemId()) ":%d,\"capacityAlarm\":%d,\"livenessAlarm\":%d,\"allowCoreThreadTimeOut\":%d}", parameter.getTenantId(),
.setTpId(parameter.getTpId()) parameter.getItemId(), parameter.getTpId(), parameter.getQueueType(), parameter.getCapacity(),
.setCoreSize(parameter.getCoreSize()) parameter.getKeepAliveTime(), parameter.getRejectedType(), parameter.getIsAlarm(),parameter.getCapacityAlarm(),
.setMaxSize(parameter.getMaxSize()) parameter.getLivenessAlarm(), parameter.getAllowCoreThreadTimeOut());
.setQueueType(parameter.getQueueType()) return getPoolContent;
.setCapacity(parameter.getCapacity())
.setKeepAliveTime(parameter.getKeepAliveTime())
.setExecuteTimeOut(parameter.getExecuteTimeOut())
.setIsAlarm(parameter.getIsAlarm())
.setCapacityAlarm(parameter.getCapacityAlarm())
.setLivenessAlarm(parameter.getLivenessAlarm())
.setAllowCoreThreadTimeOut(parameter.getAllowCoreThreadTimeOut())
.setRejectedType(parameter.getRejectedType());
return JSONUtil.toJSONString(threadPoolParameterInfo);
} }
/** /**

Loading…
Cancel
Save