diff --git a/engine/src/main/java/org/archive/crawler/frontier/AbstractFrontier.java b/engine/src/main/java/org/archive/crawler/frontier/AbstractFrontier.java index 194f89ed..269574c4 100644 --- a/engine/src/main/java/org/archive/crawler/frontier/AbstractFrontier.java +++ b/engine/src/main/java/org/archive/crawler/frontier/AbstractFrontier.java @@ -170,6 +170,7 @@ public abstract class AbstractFrontier public void stop() { terminate(); + ArchiveUtils.closeQuietly(this.recover); } @@ -643,8 +644,6 @@ public abstract class AbstractFrontier synchronized public void terminate() { requestState(State.FINISH); - // TODO: move this recover-cleanup to manager thread? - ArchiveUtils.closeQuietly(this.recover); } /**