Contents

def set_sidekiq_lock(worker_class, payload)
  options = worker_class.get_sidekiq_options['lock']
  Thread.current[Sidekiq::Lock::THREAD_KEY] = Sidekiq::Lock::RedisLock.new(options, payload)
end

def clear_sidekiq_lock
  Thread.current[Sidekiq::Lock::THREAD_KEY] = nil
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sidekiq-lock-0.3.1	lib/sidekiq/lock/testing/inline.rb
sidekiq-lock-0.3.0	lib/sidekiq/lock/testing/inline.rb
sidekiq-lock-0.2.0	lib/sidekiq/lock/testing/inline.rb