Module: Resque::Plugins::Pause

Defined in:
lib/version.rb,
lib/resque-pause/plugins/pause.rb

Constant Summary collapse

VERSION =
'0.3.0'
PAUSE_CHECK_INTERVAL =

seconds to wait when queue is paused

10

Instance Method Summary collapse

Instance Method Details

#before_perform_pause(*args) ⇒ Object



6
7
8
9
10
11
# File 'lib/resque-pause/plugins/pause.rb', line 6

def before_perform_pause(*args)
  if ResquePauseHelper.paused?(@queue)
    Kernel.sleep(@pause_check_interval || Resque::Plugins::Pause::PAUSE_CHECK_INTERVAL)
    ResquePauseHelper.check_paused(:queue => @queue, :class => self, :args => args)
  end
end