fix: 解决 RabbitMQ 多数据源声明同名交换机判断 delay 时 toMap 冲突

Author: cadecode

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/rabbit/RabbitCallback.java

@@ -32,7 +32,7 @@ public class RabbitCallback implements ConfirmCallback, ReturnsCallback, Initial
     /**
      * 交换机名称映射
      */
-    private Map<String, Exchange> exchangeNameMap;
+    private Map<String, List<Exchange>> exchangeNameMap;
 
     private final List<Exchange> exchanges;
 
@@ -75,11 +75,12 @@ public void returnedMessage(ReturnedMessage returned) {
      */
     private boolean isExchangeDelayed(String exchangeName) {
         if (ObjUtil.isEmpty(exchangeNameMap)) {
-            exchangeNameMap = exchanges.stream().collect(Collectors.toMap(Exchange::getName, o -> o));
+            exchangeNameMap = exchanges.stream().collect(Collectors.groupingBy(Exchange::getName, Collectors.toList()));
         }
         // 若是 delay 交换机
-        Exchange exchange = exchangeNameMap.get(exchangeName);
-        return ObjUtil.isNotNull(exchange) && (exchange.isDelayed() || RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType()));
+        List<Exchange> exchangeList = exchangeNameMap.get(exchangeName);
+        return exchangeList.stream()
+                .allMatch(exchange -> ObjUtil.isNotNull(exchange) && (exchange.isDelayed() || RabbitConst.EXC_TYPE_DELAYED.equals(exchange.getType())));
     }
 
     @Override