ソースを参照

WsClient 中根据 logstash 参数的值来决定 FileReader 是否启用

reghao 2 ヶ月 前
コミット
2720a5400d
1 ファイル変更4 行追加1 行削除
  1. 4 1
      agent/src/main/java/cn/reghao/bnt/agent/ws/WsClient.java

+ 4 - 1
agent/src/main/java/cn/reghao/bnt/agent/ws/WsClient.java

@@ -45,7 +45,10 @@ public class WsClient implements MessageSender {
         this.webSocketListener = new WebSocketListenerImpl(this, logstash, eventCenter, machineEvent);
         this.retry = true;
         this.retryCount = 0;
-        fileReader.start(this);
+
+        if (logstash) {
+            fileReader.start(this);
+        }
         Logger.getLogger(OkHttpClient.class.getName()).setLevel(Level.FINE);
     }