didfet 10 years ago
parent
commit
e055ac61bb
2 changed files with 6 additions and 1 deletions
  1. 1 1
      pom.xml
  2. 5 0
      src/main/java/info/fetter/logstashforwarder/Forwarder.java

+ 1 - 1
pom.xml

@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>logstash-forwarder-java</groupId>
 	<artifactId>logstash-forwarder-java</artifactId>
-	<version>0.2.1</version>
+	<version>0.2.2-SNAPSHOT</version>
 	<name>logstash-forwarder-java</name>
 	<description>Java version of logstash forwarder</description>
 	<url>https://github.com/didfet/logstash-forwarder-java</url>

+ 5 - 0
src/main/java/info/fetter/logstashforwarder/Forwarder.java

@@ -129,6 +129,11 @@ public class Forwarder {
 				inputReader.setAdapter(adapter);
 			} catch(Exception ex) {
 				logger.error("Failed to connect to server " + serverList.get(randomServerIndex) + " : " + ex.getMessage());
+				try {
+					Thread.sleep(networkTimeout);
+				} catch (InterruptedException e) {
+					logger.error(e.getMessage());
+				}
 			}
 		}
 	}