lib/sidekiq/throttled.rb in sidekiq-throttled-0.6.6 vs lib/sidekiq/throttled.rb in sidekiq-throttled-0.6.7
- old
+ new
@@ -77,11 +77,11 @@
#
# @param [String] message Job's JSON payload
# @return [Boolean]
def throttled?(message)
message = JSON.parse message
- job = message.fetch("class".freeze) { return false }
- jid = message.fetch("jid".freeze) { return false }
+ job = message.fetch("class") { return false }
+ jid = message.fetch("jid") { return false }
Registry.get job do |strategy|
return strategy.throttled?(jid, *message["args"])
end