class Sidekiq::Lock::Middleware
Public Instance Methods
call(worker, msg, _queue) { || ... }
click to toggle source
# File lib/sidekiq/lock/middleware.rb, line 4 def call(worker, msg, _queue) options = lock_options(worker) setup_lock(options, msg['args']) unless options.nil? yield end
Private Instance Methods
lock_options(worker)
click to toggle source
# File lib/sidekiq/lock/middleware.rb, line 17 def lock_options(worker) worker.class.get_sidekiq_options['lock'] end
setup_lock(options, payload)
click to toggle source
# File lib/sidekiq/lock/middleware.rb, line 13 def setup_lock(options, payload) Sidekiq.lock_container.store(RedisLock.new(options, payload)) end