From e055ac61bb843b8da74040c2bca337f7ee34cd9b Mon Sep 17 00:00:00 2001
From: didfet <didfet@free.fr>
Date: Thu, 18 Jun 2015 20:48:21 +0200
Subject: [PATCH] Fix bug #11.

---
 pom.xml                                                    | 2 +-
 src/main/java/info/fetter/logstashforwarder/Forwarder.java | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index 95158c3..6832686 100644
--- a/pom.xml
+++ b/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>
diff --git a/src/main/java/info/fetter/logstashforwarder/Forwarder.java b/src/main/java/info/fetter/logstashforwarder/Forwarder.java
index 9ae9c09..fd6320b 100644
--- a/src/main/java/info/fetter/logstashforwarder/Forwarder.java
+++ b/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());
+				}
 			}
 		}
 	}