lib/sidekiq/extensions/manager.rb in sidekiq-limit_fetch-4.4.0 vs lib/sidekiq/extensions/manager.rb in sidekiq-limit_fetch-4.4.1

@@ -1,22 +1,25 @@
-class Sidekiq::Manager
-  module InitLimitFetch
-    def initialize(options={})
-      if Sidekiq::LimitFetch.post_7?
-        options.config[:fetch] = Sidekiq::LimitFetch
-      else
-        options[:fetch] = Sidekiq::LimitFetch
+# frozen_string_literal: true
+
+module Sidekiq
+  class Manager
+    module InitLimitFetch
+      def initialize(capsule_or_options)
+        if Sidekiq::LimitFetch.post_7?
+          capsule_or_options.config[:fetch_class] = Sidekiq::LimitFetch
+        else
+          capsule_or_options[:fetch] = Sidekiq::LimitFetch
+        end
+        super
       end
-      
-      super
-    end
 
-    def start
-      # In sidekiq 6.5.0 the variable @options has been renamed to @config
-      Sidekiq::LimitFetch::Queues.start @options || @config
-      Sidekiq::LimitFetch::Global::Monitor.start!
-      super
+      def start
+        # In sidekiq 6.5.0 the variable @options has been renamed to @config
+        Sidekiq::LimitFetch::Queues.start @options || @config
+        Sidekiq::LimitFetch::Global::Monitor.start!
+        super
+      end
     end
-  end
 
-  prepend InitLimitFetch
+    prepend InitLimitFetch
+  end
 end