ShenYu Admin Cluster, websocket #5448

apache · Jul 4, 2024 · 55f86c7 · 55f86c7
1 parent 520e0ac
commit 55f86c7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcher.java b/shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcher.java
@@ -78,7 +78,9 @@ public void onApplicationEvent(@NotNull final DataChangedEvent event) {
                 LOG.info("received DataChangedEvent, not master, pass");
                 return;
             }
-            LOG.info("received DataChangedEvent, dispatching, event:{}", JsonUtils.toJson(event));
+            if (LOG.isDebugEnabled()) {
+                LOG.debug("received DataChangedEvent, dispatching, event:{}", JsonUtils.toJson(event));
+            }
             switch (event.getGroupKey()) {
                 case APP_AUTH:
                     listener.onAppAuthChanged((List<AppAuthData>) event.getSource(), event.getEventType());

diff --git a/.../main/java/org/apache/shenyu/plugin/sync/data/websocket/client/ShenyuWebsocketClient.java b/.../main/java/org/apache/shenyu/plugin/sync/data/websocket/client/ShenyuWebsocketClient.java
@@ -152,7 +152,9 @@ public void onOpen(final ServerHandshake serverHandshake) {
 
     @Override
     public void onMessage(final String result) {
-        LOG.info("onMessage server[{}] result({})", this.getURI().toString(), result);
+        if (LOG.isDebugEnabled()) {
+            LOG.debug("onMessage server[{}] result({})", this.getURI().toString(), result);
+        }
 
         Map<String, Object> jsonToMap = JsonUtils.jsonToMap(result);
         Object eventType = jsonToMap.get(RunningModeConstants.EVENT_TYPE);