diff --git a/src/main/java/info/fetter/logstashforwarder/Forwarder.java b/src/main/java/info/fetter/logstashforwarder/Forwarder.java index cefbdf5..323af77 100644 --- a/src/main/java/info/fetter/logstashforwarder/Forwarder.java +++ b/src/main/java/info/fetter/logstashforwarder/Forwarder.java @@ -128,7 +128,11 @@ public class Forwarder { fileReader.setAdapter(adapter); inputReader.setAdapter(adapter); } catch(Exception ex) { - logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : ",ex); + if(logger.isDebugEnabled()) { + logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : ", ex); + } else { + logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : " + ex.getMessage()); + } try { Thread.sleep(networkTimeout); } catch (InterruptedException e) { diff --git a/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java b/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java index 405663c..b07a27b 100644 --- a/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java +++ b/src/main/java/info/fetter/logstashforwarder/protocol/LumberjackClient.java @@ -67,6 +67,13 @@ public class LumberjackClient implements ProtocolAdapter { this.port = port; try { + if(keyStorePath == null) { + throw new IOException("Key store not configured"); + } + if(server == null) { + throw new IOException("Server address not configured"); + } + keyStore = KeyStore.getInstance("JKS"); keyStore.load(new FileInputStream(keyStorePath), null);