class Sidekiq::BasicFetch
def retrieve_work
def retrieve_work qs = queues_cmd # 4825 Sidekiq Pro with all queues paused will return an # empty set of queues if qs.size <= 0 sleep(TIMEOUT) return nil end queue, job = redis { |conn| conn.blocking_call(TIMEOUT, "brpop", *qs, TIMEOUT) } UnitOfWork.new(queue, job, config) if queue end