From b988b1a4e7e2294635476e8217419b0c73b65870 Mon Sep 17 00:00:00 2001
From: "chen.ma" <machencoding@163.com>
Date: Mon, 29 Nov 2021 21:27:07 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=98=BB=E5=A1=9E=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E9=BB=98=E8=AE=A4=E5=AE=B9=E9=87=8F=E5=A4=A7=E5=B0=8F?=
 =?UTF-8?q?.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../hippo4j/config/service/biz/impl/ConfigServiceImpl.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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<Integer> queueTypes = Stream.of(1, 2, 3, 6, 9).collect(Collectors.toList());