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 6d4d2d26..a2f2c0e1 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 @@ -219,7 +219,7 @@ public enum BlockingQueueTypeEnum { if (typeEnum == null) { return null; } - return typeEnum.of(); + return Objects.isNull(capacity) ? typeEnum.of() : typeEnum.of(capacity); } private static final int DEFAULT_CAPACITY = 1024;