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..4f2205b4 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,11 +234,11 @@ public enum BlockingQueueTypeEnum { .map(each -> each.generateBlockingQueue()) .findFirst() .orElseGet(() -> { - int temCapacity = capacity; + Integer tempCapacity = capacity; if (capacity == null || capacity <= 0) { - temCapacity = DEFAULT_CAPACITY; + tempCapacity = DEFAULT_CAPACITY; } - return new LinkedBlockingQueue(temCapacity); + return new LinkedBlockingQueue(tempCapacity); }); }