[type:bugfix] fix sync all error

apache · Nov 9, 2024 · a17be3a · a17be3a
1 parent b9f18c8
commit a17be3a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...rc/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketDataChangedListener.java b/...rc/main/java/org/apache/shenyu/admin/listener/websocket/WebsocketDataChangedListener.java
@@ -47,8 +47,10 @@ public class WebsocketDataChangedListener implements DataChangedListener {
     public void onPluginChanged(final List<PluginData> pluginDataList, final DataEventTypeEnum eventType) {
         WebsocketData<PluginData> websocketData =
                 new WebsocketData<>(ConfigGroupEnum.PLUGIN.name(), eventType.name(), pluginDataList);
-        String namespaceId = pluginDataList.stream().map(value -> StringUtils.defaultString(value.getNamespaceId(), SYS_DEFAULT_NAMESPACE_ID)).findFirst().get();
-        WebsocketCollector.send(namespaceId, GsonUtils.getInstance().toJson(websocketData), eventType);
+        if (CollectionUtils.isNotEmpty(pluginDataList)) {
+            String namespaceId = pluginDataList.stream().map(value -> StringUtils.defaultString(value.getNamespaceId(), SYS_DEFAULT_NAMESPACE_ID)).findFirst().get();
+            WebsocketCollector.send(namespaceId, GsonUtils.getInstance().toJson(websocketData), eventType);
+        }
     }
 
     @Override