Febbweiss/logstash-forwarder-java
1
0
Fork 0
mirror of https://github.com/Febbweiss/logstash-forwarder-java.git synced 2026-03-04 22:25:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug #10.

Browse Source
This commit is contained in:
didfet
2015-06-12 18:14:31 +02:00
parent 29c413d7cb
commit 1f594d5206
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/info/fetter/logstashforwarder/FileReader.java
View File

@@ -53,7 +53,12 @@ public class FileReader extends Reader {
eventCount += readFile(state, spoolSize - eventCount); eventCount += readFile(state, spoolSize - eventCount);
} }
if(eventCount > 0) { 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) { for(FileState state : fileList) {
state.setPointer(pointerMap.get(state.getFile())); state.setPointer(pointerMap.get(state.getFile()));