module ResqueUnitWithoutMock::ResqueHelpers::ClassMethods
Public Instance Methods
queue_for(klass)
click to toggle source
# File lib/resque_unit_without_mock/resque_helpers.rb, line 23 def queue_for(klass) klass.instance_variable_get(:@queue) || (klass.respond_to?(:queue) && klass.queue) end
queued(queue_name=:normal)
click to toggle source
# File lib/resque_unit_without_mock/resque_helpers.rb, line 19 def queued(queue_name=:normal) Resque.redis.lrange("queue:#{queue_name}", 0, -1) end
reset!()
click to toggle source
# File lib/resque_unit_without_mock/resque_helpers.rb, line 7 def reset! end
run!(queue_name=:normal)
click to toggle source
# File lib/resque_unit_without_mock/resque_helpers.rb, line 10 def run!(queue_name=:normal) jobs = [] loop do job = Resque.reserve(queue_name) job ? (jobs << job) : break end jobs.each(&:perform) end