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