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