fix: 判断交换机 delay 方法空指针

cadecode · cadecode · commit dca79e4faba5 · 2023-09-12T16:03:29.000+08:00
diff --git a/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/rabbit/RabbitCallback.java b/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/rabbit/RabbitCallback.java
@@ -79,7 +79,7 @@ private boolean isExchangeDelayed(String exchangeName) {
         }
         // 若是 delay 交换机
         Exchange exchange = exchangeNameMap.get(exchangeName);
-        return exchange.isDelayed() || RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType());
+        return ObjUtil.isNotNull(exchange) && (exchange.isDelayed() || RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType()));
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -79,7 +79,7 @@ private boolean isExchangeDelayed(String exchangeName) {`
`79`	`79`	`}`
`80`	`80`	`// 若是 delay 交换机`
`81`	`81`	`Exchange exchange = exchangeNameMap.get(exchangeName);`
`82`		`- return exchange.isDelayed() \|\| RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType());`
	`82`	`+ return ObjUtil.isNotNull(exchange) && (exchange.isDelayed() \|\| RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType()));`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`@Override`