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
super_initialize(parent, score, item)
Alias for: new