Class: Sidekiq::LimitFetch

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/limit_fetch/queues.rb,
lib/sidekiq/limit_fetch.rb

Defined Under Namespace

Modules: Global, Local, Singleton Classes: Queues, UnitOfWork

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ LimitFetch

Returns a new instance of LimitFetch.



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

def initialize(options)
  @queues = Queues.new options
end

Class Method Details

.bulk_requeue(jobs) ⇒ Object 



16
17
18
 
# File 'lib/sidekiq/limit_fetch.rb', line 16

def self.bulk_requeue(jobs)
  Sidekiq::BasicFetch.bulk_requeue jobs
end

Instance Method Details

#retrieve_work ⇒ Object 



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

def retrieve_work
  queue, message = fetch_message
  UnitOfWork.new queue, message if message
end