From d6a03cc2fecd22d4dc5db5483b86f4b674de9f6a Mon Sep 17 00:00:00 2001
From: didfet <didfet@free.fr>
Date: Sat, 4 Apr 2015 23:37:31 +0200
Subject: [PATCH] Implemented stdin input (issue #5).

---
 src/main/java/info/fetter/logstashforwarder/Forwarder.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/info/fetter/logstashforwarder/Forwarder.java b/src/main/java/info/fetter/logstashforwarder/Forwarder.java
index 43d029e..8288185 100644
--- a/src/main/java/info/fetter/logstashforwarder/Forwarder.java
+++ b/src/main/java/info/fetter/logstashforwarder/Forwarder.java
@@ -121,6 +121,7 @@ public class Forwarder {
 				logger.info("Trying to connect to " + serverList.get(randomServerIndex));
 				adapter = new LumberjackClient(configManager.getConfig().getNetwork().getSslCA(),serverAndPort[0],Integer.parseInt(serverAndPort[1]), networkTimeout);
 				fileReader.setAdapter(adapter);
+				inputReader.setAdapter(adapter);
 			} catch(Exception ex) {
 				logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : " + ex.getMessage());
 			}