From 598630cc23617c75da17b55d916faca005b7a3a0 Mon Sep 17 00:00:00 2001 From: Athou Date: Fri, 7 Jun 2013 15:56:24 +0200 Subject: [PATCH] give back the feed to the queue --- .../commafeed/backend/pubsubhubbub/SubscriptionHandler.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/commafeed/backend/pubsubhubbub/SubscriptionHandler.java b/src/main/java/com/commafeed/backend/pubsubhubbub/SubscriptionHandler.java index 6ca377da..20b807d2 100644 --- a/src/main/java/com/commafeed/backend/pubsubhubbub/SubscriptionHandler.java +++ b/src/main/java/com/commafeed/backend/pubsubhubbub/SubscriptionHandler.java @@ -19,6 +19,7 @@ import org.slf4j.LoggerFactory; import com.commafeed.backend.HttpGetter; import com.commafeed.backend.dao.FeedDAO; +import com.commafeed.backend.feeds.FeedRefreshTaskGiver; import com.commafeed.backend.feeds.FeedUtils; import com.commafeed.backend.model.Feed; import com.commafeed.backend.services.ApplicationSettingsService; @@ -33,7 +34,7 @@ public class SubscriptionHandler { ApplicationSettingsService applicationSettingsService; @Inject - FeedDAO feedDAO; + FeedRefreshTaskGiver taskGiver; public void subscribe(Feed feed) { @@ -80,7 +81,7 @@ public class SubscriptionHandler { && StringUtils.contains(message, pushpressError)) { String[] tokens = message.split(" "); feed.setPushTopic(tokens[tokens.length - 1]); - feedDAO.saveOrUpdate(feed); + taskGiver.giveBack(feed); log.debug("handled pushpress subfeed {} : {}", topic, feed.getPushTopic()); } else {