Module: Resque
- Defined in:
- lib/resque_manager/overrides/resque/resque.rb,
lib/resque_manager/overrides/resque/worker.rb,
lib/resque_manager/overrides/resque_status/hash.rb,
lib/resque_manager/overrides/resque/failure/redis.rb,
lib/resque_manager/overrides/resque_status/status.rb,
lib/resque_manager/overrides/resque_status/chained_status.rb
Defined Under Namespace
Modules: Failure, Plugins Classes: Worker
Class Method Summary collapse
Class Method Details
.throttle(queue, limit = 10000, sleep_for = 60) ⇒ Object
2 3 4 5 6 7 |
# File 'lib/resque_manager/overrides/resque/resque.rb', line 2 def self.throttle(queue, limit = 10000, sleep_for = 60) loop do break if Resque.size(queue.to_s) < limit sleep sleep_for end end |