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