From 4a13ceb5bc99f058f884073c976193c427c7d7bc Mon Sep 17 00:00:00 2001 From: Will Leinweber Date: Wed, 4 May 2011 17:14:55 -0700 Subject: [PATCH] move @paused into a #paused? method --- lib/resque/worker.rb | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/lib/resque/worker.rb b/lib/resque/worker.rb index e8d811afb..5cbe3d437 100644 --- a/lib/resque/worker.rb +++ b/lib/resque/worker.rb @@ -116,7 +116,7 @@ def work(interval = 5.0, &block) loop do break if shutdown? - if not @paused and job = reserve + if not paused? and job = reserve log "got: #{job.inspect}" run_hook :before_fork, job working_on job @@ -136,7 +136,7 @@ def work(interval = 5.0, &block) else break if interval.zero? log! "Sleeping for #{interval} seconds" - procline @paused ? "Paused" : "Waiting for #{@queues.join(',')}" + procline paused? ? "Paused" : "Waiting for #{@queues.join(',')}" sleep interval end end @@ -298,6 +298,11 @@ def kill_child end end + # are we paused? + def paused? + @paused + end + # Stop processing jobs after the current one has completed (if we're # currently running one). def pause_processing