From 17a5ef882fd9fb889f61c183911ad23856a89e59 Mon Sep 17 00:00:00 2001
From: Athou <jeremiepanzer@gmail.com>
Date: Mon, 18 Aug 2014 15:30:25 +0200
Subject: [PATCH] smaller session boundary

---
 .../commafeed/backend/feed/FeedRefreshTaskGiver.java | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/commafeed/backend/feed/FeedRefreshTaskGiver.java b/src/main/java/com/commafeed/backend/feed/FeedRefreshTaskGiver.java
index e9ef087a..96e264da 100644
--- a/src/main/java/com/commafeed/backend/feed/FeedRefreshTaskGiver.java
+++ b/src/main/java/com/commafeed/backend/feed/FeedRefreshTaskGiver.java
@@ -71,15 +71,13 @@ public class FeedRefreshTaskGiver implements Managed {
 						FeedRefreshContext context = new UnitOfWork<FeedRefreshContext>(sessionFactory) {
 							@Override
 							protected FeedRefreshContext runInSession() throws Exception {
-								FeedRefreshContext context = queues.take();
-								if (context != null) {
-									feedRefreshed.mark();
-									worker.updateFeed(context);
-								}
-								return context;
+								return queues.take();
 							}
 						}.run();
-						if (context == null) {
+						if (context != null) {
+							feedRefreshed.mark();
+							worker.updateFeed(context);
+						} else {
 							log.debug("nothing to do, sleeping for 15s");
 							threadWaited.mark();
 							try {