修改空broker列表查询报错

jd-opensource · Oct 15, 2020 · 99fe180 · 99fe180
1 parent 1d2a271
commit 99fe180
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/...e-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java b/...e-data-service/src/main/java/org/joyqueue/service/impl/BrokerGroupRelatedServiceImpl.java
@@ -47,12 +47,14 @@ public int deleteByGroupId(long groupId) {
 
     @Override
     public Map<Long, Identity> findGroupByBrokerIds(List<Long> brokerIds) {
-        List<BrokerGroupRelated> brokerGroupRelateds = repository.findByBrokerIds(brokerIds);
-        if (CollectionUtils.isNotEmpty(brokerGroupRelateds)) {
-            return brokerGroupRelateds.stream()
-                    .filter(brokerGroupRelated -> brokerGroupRelated.getGroup() != null)
-                    .collect(Collectors.toMap(BrokerGroupRelated::getId,
-                            BrokerGroupRelated::getGroup));
+        if (CollectionUtils.isNotEmpty(brokerIds)) {
+            List<BrokerGroupRelated> brokerGroupRelateds = repository.findByBrokerIds(brokerIds);
+            if (CollectionUtils.isNotEmpty(brokerGroupRelateds)) {
+                return brokerGroupRelateds.stream()
+                        .filter(brokerGroupRelated -> brokerGroupRelated.getGroup() != null)
+                        .collect(Collectors.toMap(BrokerGroupRelated::getId,
+                                BrokerGroupRelated::getGroup));
+            }
         }
         return Collections.emptyMap();
     }