diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
index 32145def..410dec51 100644
--- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
+++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
@@ -64,7 +64,7 @@ public class FeedRefreshUpdater {
 		pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy() {
 			@Override
 			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);
 			}
 		});
diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java
index 2351b540..6a44ab3b 100644
--- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java
+++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java
@@ -143,6 +143,10 @@ public class FeedRefreshWorker {
 			}
 			if (topic.startsWith("www.")) {
 				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);
 			FeedPushInfo info = feed.getPushInfo();