diff --git a/src/main/java/com/commafeed/backend/DatabaseCleaner.java b/src/main/java/com/commafeed/backend/DatabaseCleaner.java index 47ab382b..39179c3b 100644 --- a/src/main/java/com/commafeed/backend/DatabaseCleaner.java +++ b/src/main/java/com/commafeed/backend/DatabaseCleaner.java @@ -15,6 +15,7 @@ import com.commafeed.backend.dao.FeedEntryDAO; import com.commafeed.backend.dao.FeedSubscriptionDAO; import com.commafeed.backend.model.Feed; import com.commafeed.backend.model.FeedSubscription; +import com.commafeed.backend.services.ApplicationSettingsService; import com.google.common.collect.Lists; public class DatabaseCleaner { @@ -30,6 +31,9 @@ public class DatabaseCleaner { @Inject FeedSubscriptionDAO feedSubscriptionDAO; + @Inject + ApplicationSettingsService applicationSettingsService; + public long cleanFeedsWithoutSubscriptions() { long total = 0; @@ -75,7 +79,9 @@ public class DatabaseCleaner { long total = 0; int deleted = -1; do { - List fcs = feedDAO.findDuplicates(0, 10, 1); + List fcs = feedDAO + .findDuplicates(0, applicationSettingsService.get() + .getDatabaseUpdateThreads(), 1); deleted = fcs.size(); List threads = Lists.newArrayList();