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 #21 to test

Browse Source
This commit is contained in:
didfet
2016-09-02 14:38:51 +02:00
parent dfe74164e3
commit b3a8e3e1f3
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>logstash-forwarder-java</groupId> <groupId>logstash-forwarder-java</groupId>
<artifactId>logstash-forwarder-java</artifactId> <artifactId>logstash-forwarder-java</artifactId>
<version>0.2.4</version> <version>0.2.5-FIX-ISSUE-21</version>
<name>logstash-forwarder-java</name> <name>logstash-forwarder-java</name>
<description>Java version of logstash forwarder</description> <description>Java version of logstash forwarder</description>
<url>https://github.com/didfet/logstash-forwarder-java</url> <url>https://github.com/didfet/logstash-forwarder-java</url>

1
src/main/java/info/fetter/logstashforwarder/FileWatcher.java
View File

@@ -325,6 +325,7 @@ public class FileWatcher {
List<File> markedList = null; List<File> markedList = null;
for(File file : oldWatchMap.keySet()) { for(File file : oldWatchMap.keySet()) {
FileState state = oldWatchMap.get(file); FileState state = oldWatchMap.get(file);
state.setMatchedToNewFile(false);
if(state.getRandomAccessFile() == null) { if(state.getRandomAccessFile() == null) {
state.setDeleted(); state.setDeleted();
} }