Febbweiss/logstash-forwarder-java
1
0
Fork 0
mirror of https://github.com/Febbweiss/logstash-forwarder-java.git synced 2026-03-04 22:25:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implemented stdin input (issue #5).

Browse Source
This commit is contained in:
didfet
2015-04-04 23:37:31 +02:00
parent 69d181dfd0
commit d6a03cc2fe
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/info/fetter/logstashforwarder/Forwarder.java
View File

@@ -121,6 +121,7 @@ public class Forwarder {
logger.info("Trying to connect to " + serverList.get(randomServerIndex)); logger.info("Trying to connect to " + serverList.get(randomServerIndex));
adapter = new LumberjackClient(configManager.getConfig().getNetwork().getSslCA(),serverAndPort[0],Integer.parseInt(serverAndPort[1]), networkTimeout); adapter = new LumberjackClient(configManager.getConfig().getNetwork().getSslCA(),serverAndPort[0],Integer.parseInt(serverAndPort[1]), networkTimeout);
fileReader.setAdapter(adapter); fileReader.setAdapter(adapter);
inputReader.setAdapter(adapter);
} catch(Exception ex) { } catch(Exception ex) {
logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : " + ex.getMessage()); logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : " + ex.getMessage());
} }