Febbweiss/logstash-forwarder-java
1
0
Fork 0
mirror of https://github.com/Febbweiss/logstash-forwarder-java.git synced 2026-03-05 06:35:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Solve problem with sincedb.

Browse Source
This commit is contained in:
didfet
2016-08-08 21:03:55 +02:00
parent f44ff80bec
commit b94203dfab
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -49,12 +49,6 @@ public class FileWatcher {
private String sincedbFile = null; private String sincedbFile = null;
public FileWatcher() { public FileWatcher() {
try {
logger.debug("Loading saved states");
savedStates = Registrar.readStateFromJson(sincedbFile);
} catch(Exception e) {
logger.warn("Could not load saved states : " + e.getMessage(), e);
}
} }
public void initialize() throws IOException { public void initialize() throws IOException {
@@ -366,6 +360,12 @@ public class FileWatcher {
public void setSincedb(String sincedbFile) { public void setSincedb(String sincedbFile) {
this.sincedbFile = sincedbFile; this.sincedbFile = sincedbFile;
try {
logger.debug("Loading saved states");
savedStates = Registrar.readStateFromJson(sincedbFile);
} catch(Exception e) {
logger.warn("Could not load saved states : " + e.getMessage(), e);
}
} }
} }