diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/BlockingQueueTypeEnum.java b/hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/BlockingQueueTypeEnum.java index a1a77720..6f80ab7e 100644 --- a/hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/BlockingQueueTypeEnum.java +++ b/hippo4j-common/src/main/java/cn/hippo4j/common/executor/support/BlockingQueueTypeEnum.java @@ -234,7 +234,7 @@ public enum BlockingQueueTypeEnum { .map(each -> each.generateBlockingQueue()) .findFirst() .orElseGet(() -> { - int temCapacity = capacity; + Integer temCapacity = capacity; if (capacity == null || capacity <= 0) { temCapacity = DEFAULT_CAPACITY; }