Class: Sidekiq::LimitFetch

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

Defined Under Namespace

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

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Redis

#determine_namespace, #nonblocking_redis, #redis

Constructor Details

#initialize(options) ⇒ LimitFetch

Returns a new instance of LimitFetch.



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

def initialize(options)
  Global::Monitor.start!
  @queues = Queues.new options.merge(namespace: determine_namespace)
end

Class Method Details

.bulk_requeue(*args) ⇒ Object 



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

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

Instance Method Details

#retrieve_work ⇒ Object 



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

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