module Sidekiq::DeadSetKill

Public Instance Methods

kill(message) click to toggle source
# File lib/sidekiq/extensions/dead_set.rb, line 10
def kill(message)
  now = Time.now.to_f
  Sidekiq.redis do |conn|
    conn.multi do
      conn.zadd(name, now.to_f.to_s, message)
      conn.zremrangebyscore(name, '-inf', now - self.class.timeout)
      conn.zremrangebyrank(name, 0, - self.class.max_jobs)
    end
  end
end