From db431a343b035956668923cc6806da1294e5c223 Mon Sep 17 00:00:00 2001 From: Kazi Akib Javed Date: Tue, 6 Jun 2023 21:44:50 +0600 Subject: [PATCH] refactord to resolve the flaky --- .../hippo4j/common/toolkit/ContentUtil.java | 24 ++++++------------- 1 file changed, 7 insertions(+), 17 deletions(-) diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java b/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java index ae5b6dfe..a4f5fcb4 100644 --- a/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java +++ b/hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java @@ -19,7 +19,6 @@ package cn.hippo4j.common.toolkit; import cn.hippo4j.common.constant.Constants; import cn.hippo4j.common.model.ThreadPoolParameter; -import cn.hippo4j.common.model.ThreadPoolParameterInfo; /** * Content util. @@ -33,22 +32,13 @@ public class ContentUtil { * @return dynamic thread-pool content str */ public static String getPoolContent(ThreadPoolParameter parameter) { - ThreadPoolParameterInfo threadPoolParameterInfo = new ThreadPoolParameterInfo(); - threadPoolParameterInfo.setTenantId(parameter.getTenantId()) - .setItemId(parameter.getItemId()) - .setTpId(parameter.getTpId()) - .setCoreSize(parameter.getCoreSize()) - .setMaxSize(parameter.getMaxSize()) - .setQueueType(parameter.getQueueType()) - .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); + String getPoolContent = String.format("{\"tenantId\":\"%s\",\"itemId\":\"%s\",\"tpId\":" + + "\"%s\",\"queueType\":%d,\"capacity\":%d,\"keepAliveTime\":%d,\"rejectedType\":%d,\"isAlarm\"" + + ":%d,\"capacityAlarm\":%d,\"livenessAlarm\":%d,\"allowCoreThreadTimeOut\":%d}", parameter.getTenantId(), + parameter.getItemId(), parameter.getTpId(), parameter.getQueueType(), parameter.getCapacity(), + parameter.getKeepAliveTime(), parameter.getRejectedType(), parameter.getIsAlarm(),parameter.getCapacityAlarm(), + parameter.getLivenessAlarm(), parameter.getAllowCoreThreadTimeOut()); + return getPoolContent; } /**