diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java index cd94dfaf..5e07ab1a 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java @@ -4,7 +4,6 @@ import java.util.Calendar; import java.util.List; import java.util.Queue; -import javax.annotation.PostConstruct; import javax.ejb.Lock; import javax.ejb.LockType; import javax.ejb.Singleton; @@ -28,21 +27,13 @@ public class FeedRefreshTaskGiver { @Inject MetricsBean metricsBean; - private int backgroundThreads; private Queue queue = Queues.newConcurrentLinkedQueue(); - @PostConstruct - public void init() { - backgroundThreads = applicationSettingsService.get() - .getBackgroundThreads(); - } - @Lock(LockType.WRITE) public Feed take() { Feed feed = queue.poll(); if (feed == null) { - List feeds = feedDAO - .findNextUpdatable(50 * backgroundThreads); + List feeds = feedDAO.findNextUpdatable(50); for (Feed f : feeds) { queue.add(f); f.setLastUpdated(Calendar.getInstance().getTime());