Merge pull request chrisboulton#34 from mhagstrand/SleepingWithDelayI…

…nQueue Fix bug where scheduler sleeps when processing a delayed queue
read2me-online · Nov 28, 2016 · 5954c98 · 5954c98
2 parents 894b41d + 073f25f
commit 5954c98
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/ResqueScheduler/Worker.php b/lib/ResqueScheduler/Worker.php
@@ -55,9 +55,9 @@ public function work($interval = null)
 	 */
 	public function handleDelayedItems($timestamp = null)
 	{
-		while (($timestamp = ResqueScheduler::nextDelayedTimestamp($timestamp)) !== false) {
+		while (($oldestJobTimestamp = ResqueScheduler::nextDelayedTimestamp($timestamp)) !== false) {
 			$this->updateProcLine('Processing Delayed Items');
-			$this->enqueueDelayedItemsForTimestamp($timestamp);
+			$this->enqueueDelayedItemsForTimestamp($oldestJobTimestamp);
 		}
 	}