From 2b4c556ca08c4bcb7ebcc94b1ad05320b7057da9 Mon Sep 17 00:00:00 2001 From: didfet Date: Tue, 17 Mar 2015 16:04:32 +0100 Subject: [PATCH] Bug correction. --- src/main/java/info/fetter/logstashforwarder/FileReader.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/info/fetter/logstashforwarder/FileReader.java b/src/main/java/info/fetter/logstashforwarder/FileReader.java index 5ba30fb..dc9ad40 100644 --- a/src/main/java/info/fetter/logstashforwarder/FileReader.java +++ b/src/main/java/info/fetter/logstashforwarder/FileReader.java @@ -59,7 +59,9 @@ public class FileReader { for(FileState state : fileList) { eventCount += readFile(state, spoolSize - eventCount); } - adapter.sendEvents(eventList); + if(eventCount > 0) { + adapter.sendEvents(eventList); + } for(FileState state : fileList) { state.setPointer(pointerMap.get(state.getFile())); } @@ -82,7 +84,7 @@ public class FileReader { private long readLines(FileState state, int spaceLeftInSpool) throws IOException { RandomAccessFile reader = state.getRandomAccessFile(); - long pos = reader.getFilePointer(); + long pos = state.getPointer(); reader.seek(pos); String line = readLine(reader); while (line != null && spaceLeftInSpool > 0) {