Module: Sidekiq::LimitFetch

Extended by:
LimitFetch
Included in:
LimitFetch
Defined in:
lib/sidekiq/limit_fetch.rb

Defined Under Namespace

Modules: Global, Instances, Queues Classes: UnitOfWork

Instance Method Summary collapse

Instance Method Details

#bulk_requeue(*args) ⇒ Object 



29
30
31
 
# File 'lib/sidekiq/limit_fetch.rb', line 29

def bulk_requeue(*args)
  Sidekiq::BasicFetch.bulk_requeue(*args)
end

#new(_) ⇒ Object 



19
20
21
 
# File 'lib/sidekiq/limit_fetch.rb', line 19

def new(_)
  self
end

#retrieve_work ⇒ Object 



23
24
25
26
27
 
# File 'lib/sidekiq/limit_fetch.rb', line 23

def retrieve_work
  queue, job = redis_brpop(Queues.acquire)
  Queues.release_except(queue)
  UnitOfWork.new(queue, job) if job
end