From fd6b4a3e348ccd9fa65f4cc22d001c8b91ebd10b Mon Sep 17 00:00:00 2001 From: machen Date: Mon, 13 Mar 2023 21:21:26 +0800 Subject: [PATCH] Refactor blocking queue enum --- .../hippo4j/common/executor/support/BlockingQueueTypeEnum.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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;