lib/sidekiq/throttled.rb in sidekiq-throttled-0.16.0 vs lib/sidekiq/throttled.rb in sidekiq-throttled-0.16.1

@@ -73,14 +73,13 @@
 
       # Tells whenever job is throttled or not.
       #
       # @param [String] message Job's JSON payload
       # @return [Boolean]
-      def throttled?(message) # rubocop:disable Metrics/MethodLength
+      def throttled?(message)
         message = JSON.parse message
-        job = message.fetch("class")   { return false }
-        job = message.fetch("wrapped") { return false } if job == "ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper"
-        jid = message.fetch("jid")     { return false }
+        job = message.fetch("wrapped") { message.fetch("class") { return false } }
+        jid = message.fetch("jid") { return false }
 
         preload_constant! job
 
         Registry.get job do |strategy|
           return strategy.throttled?(jid, *message["args"])