fix: filter null channel on stop to avoid NPE

gravitee-io · Mar 5, 2024 · 3ba8c76 · 3ba8c76
1 parent 1478bfd
commit 3ba8c76
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../src/main/java/io/gravitee/exchange/controller/core/cluster/ControllerClusterManager.java b/.../src/main/java/io/gravitee/exchange/controller/core/cluster/ControllerClusterManager.java
@@ -38,6 +38,7 @@
 import io.reactivex.rxjava3.core.SingleEmitter;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
@@ -109,6 +110,7 @@ protected void doStop() throws Exception {
             .values()
             .stream()
             .map(channelManager::getChannelById)
+            .filter(Objects::nonNull)
             .toList();
 
         channels.forEach(this::channelDisconnected);