diff --git a/.classpath b/.classpath index ea14c43..300318f 100644 --- a/.classpath +++ b/.classpath @@ -17,12 +17,12 @@ - + - + diff --git a/.project b/.project index e05a8f9..611351d 100644 --- a/.project +++ b/.project @@ -17,7 +17,7 @@ - org.eclipse.jdt.core.javanature org.eclipse.m2e.core.maven2Nature + org.eclipse.jdt.core.javanature diff --git a/pom.xml b/pom.xml index 4401df2..f1e5ef1 100644 --- a/pom.xml +++ b/pom.xml @@ -3,7 +3,7 @@ 4.0.0 logstash-forwarder-java logstash-forwarder-java - 0.2.0 + 0.2.1-SNAPSHOT logstash-forwarder-java Java version of logstash forwarder https://github.com/didfet/logstash-forwarder-java diff --git a/src/main/java/info/fetter/logstashforwarder/FileWatcher.java b/src/main/java/info/fetter/logstashforwarder/FileWatcher.java index 3f320a7..5f0d9e9 100644 --- a/src/main/java/info/fetter/logstashforwarder/FileWatcher.java +++ b/src/main/java/info/fetter/logstashforwarder/FileWatcher.java @@ -315,18 +315,21 @@ public class FileWatcher { for(File file : oldWatchMap.keySet()) { FileState state = oldWatchMap.get(file); if(state.isDeleted()) { - if(markedList == null) { - markedList = new ArrayList(); + if(! file.exists()) { + if(markedList == null) { + markedList = new ArrayList(); + } + markedList.add(file); } - markedList.add(file); + try { + state.getRandomAccessFile().close(); + } catch(Exception e) {} } } if(markedList != null) { for(File file : markedList) { FileState state = oldWatchMap.remove(file); - try { - state.getRandomAccessFile().close(); - } catch(Exception e) {} + logger.trace("\tFile : " + file + " removed"); } }