class Sidekiq::Throttled::Message
Public Class Methods
Source
# File lib/sidekiq/throttled/message.rb, line 6 def initialize(item) @item = item.is_a?(Hash) ? item : parse(item) end
Public Instance Methods
Source
# File lib/sidekiq/throttled/message.rb, line 14 def job_args @item.key?("wrapped") ? @item.dig("args", 0, "arguments") : @item["args"] end
Source
# File lib/sidekiq/throttled/message.rb, line 10 def job_class @item.fetch("wrapped") { @item["class"] } end
Private Instance Methods
Source
# File lib/sidekiq/throttled/message.rb, line 24 def parse(item) item = Sidekiq.load_json(item) item.is_a?(Hash) ? item : {} rescue JSON::ParserError {} end