class Sidekiq::SortedEntry
Public Class Methods
new(parent, score, item)
click to toggle source
# File lib/sidekiq/failures/sorted_entry.rb, line 5 def initialize(parent, score, item) super_initialize(parent, score, item) # 0.3.0 compatibility @item.merge!(@item["payload"]) if @item["payload"] end
Also aliased as: super_initialize
Public Instance Methods
retry_failure()
click to toggle source
# File lib/sidekiq/failures/sorted_entry.rb, line 12 def retry_failure Sidekiq.redis do |conn| results = conn.zrangebyscore(Sidekiq::Failures::LIST_KEY, score, score) conn.zremrangebyscore(Sidekiq::Failures::LIST_KEY, score, score) results.map do |message| msg = Sidekiq.load_json(message) Sidekiq::Client.push(msg) end end end