module Sidekiq::Uniq
Constants
- VERSION
Public Instance Methods
call(worker_class, msg, queue_name, redis_pool) { || ... }
click to toggle source
# File lib/sidekiq/uniq.rb, line 6 def call(worker_class, msg, queue_name, redis_pool) unless msg['unique'] === false queue = Sidekiq::Queue.new(msg['queue']) queue.each do |job| return false if job.klass == msg['class'] && job.args === msg['args'] end end yield end