From ed16c905da2ec183be9f99d30a8b79a583a4d9f4 Mon Sep 17 00:00:00 2001 From: Kevin Date: Thu, 16 Mar 2023 09:30:25 +0800 Subject: [PATCH] =?UTF-8?q?Issue=201111-=E6=A0=B8=E5=BF=83=E9=98=BB?= =?UTF-8?q?=E5=A1=9E=E9=98=9F=E5=88=97=E6=9E=9A=E4=B8=BE=20BlockingQueueTy?= =?UTF-8?q?peEnum.createBlockingQueue(String=20blockingQueueName,=20Intege?= =?UTF-8?q?r=20capacity)=E6=8A=9B=E5=87=BANPE=E9=97=AE=E9=A2=98=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D=20(#1117)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix the NPE about null Integer convert to int,change temCapacity's type from int to Integer * refactor BlockingQueueTypeEnum --- .../common/executor/support/BlockingQueueTypeEnum.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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); }); }