lib/shoryuken/launcher.rb in shoryuken-3.1.1 vs lib/shoryuken/launcher.rb in shoryuken-3.1.2

@@ -60,12 +60,10 @@
     end
 
     def initiate_stop
       logger.info { 'Shutting down' }
 
-      @managers.each(&:stop)
-
       stop_callback
     end
 
     def start_callback
       if (callback = Shoryuken.start_callback)
@@ -88,10 +86,11 @@
     def create_managers
       Shoryuken.groups.map do |group, options|
         Shoryuken::Manager.new(
           Shoryuken::Fetcher.new(group),
           Shoryuken.polling_strategy(group).new(options[:queues]),
-          options[:concurrency]
+          options[:concurrency],
+          executor
         )
       end
     end
   end
 end