Archives/Athou_commafeed
1
0
Fork 1
mirror of https://github.com/Athou/commafeed.git synced 2026-03-21 21:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

more pubsub special cases handling

Browse Source
This commit is contained in:
Athou
2013-05-23 12:58:05 +02:00
parent 4935d4f1bc
commit dae85a2f48
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
View File

@@ -64,7 +64,7 @@ public class FeedRefreshUpdater {
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() { pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() {
@Override @Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
log.info("Thread queue full, executing in own thread."); log.debug("Thread queue full, executing in own thread.");
super.rejectedExecution(r, e); super.rejectedExecution(r, e);
} }
}); });

4
src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java
View File

@@ -143,6 +143,10 @@ public class FeedRefreshWorker {
} }
if (topic.startsWith("www.")) { if (topic.startsWith("www.")) {
topic = "http://" + topic; topic = "http://" + topic;
} else if (topic.startsWith("feed://")) {
topic = "http://" + topic.substring(7);
} else if (topic.startsWith("http") == false) {
topic = "http://" + topic;
} }
log.debug("feed {} has pubsub info: {}", feed.getUrl(), topic); log.debug("feed {} has pubsub info: {}", feed.getUrl(), topic);
FeedPushInfo info = feed.getPushInfo(); FeedPushInfo info = feed.getPushInfo();