Contents

module Resque
  module Plugins
    module Pause
      PAUSE_CHECK_INTERVAL = 10 #seconds to wait when queue is paused

      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
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
resque-pause-0.3.0	lib/resque-pause/plugins/pause.rb
resque-pause-0.2.0	lib/resque-pause/plugins/pause.rb
resque-pause-0.1.0	lib/resque-pause/plugins/pause.rb