浏览代码

cluster library update logging

HANTE 1 月之前
父节点
当前提交
bf706d03df
共有 1 个文件被更改,包括 3 次插入1 次删除
  1. 3 1
      its-cluster/src/main/java/com/its/common/cluster/service/HaClusterSlave.java

+ 3 - 1
its-cluster/src/main/java/com/its/common/cluster/service/HaClusterSlave.java

@@ -128,7 +128,9 @@ public class HaClusterSlave implements Callable<Object> {
             this.cluster.getSyncState().connect(channel);
         }
         else {
-            log.warn("HaClusterSlave: ConnectFailed: [{}, {}], {}, Cause: {}", cluster.getServerId(), cluster.getIpAddress(), cluster.getSyncPort(), future.cause().getMessage());
+            if (this.clusterConfig.isLogging()) {
+                log.warn("HaClusterSlave: ConnectFailed: [{}, {}], {}, Cause: {}", cluster.getServerId(), cluster.getIpAddress(), cluster.getSyncPort(), future.cause().getMessage());
+            }
         }
 
         if (this.clusterConfig.isLogging()) {