diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java index 92a45025..dae0553c 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/service/biz/impl/ConfigServiceImpl.java @@ -125,11 +125,14 @@ public class ConfigServiceImpl implements ConfigService { * @return */ private Integer getQueueCapacityByType(ConfigAllInfo config) { - int queueCapacity = 0; + int queueCapacity; switch (config.getQueueType()) { case 5: queueCapacity = Integer.MAX_VALUE; break; + default: + queueCapacity = config.getCapacity(); + break; } List queueTypes = Stream.of(1, 2, 3, 6, 9).collect(Collectors.toList());