Contents

module Resque
  def self.throttle(queue, limit = 10000, sleep_for = 60)
    loop do
      break if Resque.size(queue.to_s) < limit
      sleep sleep_for
    end
  end
end

Version data entries

28 entries across 28 versions & 2 rubygems

Version	Path
resque_manager-3.3.13	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.12	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.11	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.10	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.9	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.8	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.7	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.6	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.5	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.4	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.3	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.2	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.1	lib/resque_manager/overrides/resque/resque.rb
resque_manager-3.3.0	lib/resque_manager/overrides/resque/resque.rb
resque_ui-3.2.4	lib/resque_ui/overrides/resque/resque.rb
resque_ui-3.2.3	lib/resque_ui/overrides/resque/resque.rb
resque_ui-3.2.2	lib/resque_ui/overrides/resque/resque.rb
resque_ui-3.2.1	lib/resque_ui/overrides/resque/resque.rb
resque_ui-3.2.0	lib/resque_ui/overrides/resque/resque.rb
resque_ui-3.1.7	lib/resque_ui/overrides/resque/resque.rb