garrettmills/commafeed
1
0
Fork 0
forked from Archives/Athou_commafeed
Code Pull Requests Activity

setting to pause feed crawling

Browse Source
This commit is contained in:
Athou
2013-07-05 08:23:18 +02:00
parent 5f721bdc8a
commit 5530c5fd7e
4 changed files with 31 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/commafeed/backend/feeds/FeedRefreshTaskGiver.java
View File

@@ -22,6 +22,7 @@ import com.commafeed.backend.dao.FeedDAO;
import com.commafeed.backend.model.Feed;
import com.commafeed.backend.services.ApplicationSettingsService;
import com.google.api.client.util.Maps;
import com.google.common.collect.Lists;
import com.google.common.collect.Queues;
@ApplicationScoped
@@ -134,7 +135,12 @@ public class FeedRefreshTaskGiver {
Date now = new Date();
int count = 3 * backgroundThreads;
List<Feed> feeds = feedDAO.findNextUpdatable(count, getThreshold());
List<Feed> feeds = null;
if (applicationSettingsService.get().isCrawlingPaused()) {
feeds = Lists.newArrayList();
} else {
feeds = feedDAO.findNextUpdatable(count, getThreshold());
}
int size = addQueue.size();
for (int i = 0; i < size; i++) {

9
src/main/java/com/commafeed/backend/model/ApplicationSettings.java
View File

@@ -34,6 +34,7 @@ public class ApplicationSettings extends AbstractModel {
private String logLevel = Level.INFO.toString();
private boolean imageProxyEnabled;
private int queryTimeout;
private boolean crawlingPaused;
@Column(length = 255)
private String announcement;
@@ -191,4 +192,12 @@ public class ApplicationSettings extends AbstractModel {
this.queryTimeout = queryTimeout;
}
public boolean isCrawlingPaused() {
return crawlingPaused;
}
public void setCrawlingPaused(boolean crawlingPaused) {
this.crawlingPaused = crawlingPaused;
}
}