From 1f594d52066f43efdbfcaa0c521f1d7d76cfd1ec Mon Sep 17 00:00:00 2001
From: didfet <didfet@free.fr>
Date: Fri, 12 Jun 2015 18:14:31 +0200
Subject: [PATCH] Fix bug #10.

---
 .../java/info/fetter/logstashforwarder/FileReader.java     | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/info/fetter/logstashforwarder/FileReader.java b/src/main/java/info/fetter/logstashforwarder/FileReader.java
index 982340b..59597fd 100644
--- a/src/main/java/info/fetter/logstashforwarder/FileReader.java
+++ b/src/main/java/info/fetter/logstashforwarder/FileReader.java
@@ -53,7 +53,12 @@ public class FileReader extends Reader {
 			eventCount += readFile(state, spoolSize - eventCount);
 		}
 		if(eventCount > 0) {
-			adapter.sendEvents(eventList);
+			try {
+				adapter.sendEvents(eventList);
+			} catch(AdapterException e) {
+				eventList.clear(); // Be sure no events will be sent twice after reconnect
+				throw e;
+			}
 		}
 		for(FileState state : fileList) {
 			state.setPointer(pointerMap.get(state.getFile()));