Class: Sidekiq::Corral::Client

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::ClientMiddleware
Defined in:
lib/sidekiq/corral.rb

Instance Method Summary collapse

Constructor Details

#initialize(opts) ⇒ Client

Returns a new instance of Client.



46
47
48
49
 
# File 'lib/sidekiq/corral.rb', line 46

def initialize(opts)
  opts = opts.transform_keys(&:to_s)
  @exempt_queues = Array(opts["exempt_queues"]).map(&:to_s)
end

Instance Method Details

#call(_worker_class, job, _queue, _redis_pool) ⇒ Object 



51
52
53
54
55
 
# File 'lib/sidekiq/corral.rb', line 51

def call(_worker_class, job, _queue, _redis_pool)
  job["corral"] = Corral.current if Corral.current
  job["queue"] = job["corral"] if job["corral"] && !@exempt_queues.include?(job["queue"])
  yield
end