lib/shoryuken/launcher.rb in shoryuken-3.1.4 vs lib/shoryuken/launcher.rb in shoryuken-3.1.5

- old
+ new

@@ -1,12 +1,11 @@ module Shoryuken class Launcher include Util def initialize - @managers = create_managers - @shutdowning = Concurrent::AtomicBoolean.new(false) + @managers = create_managers end def start logger.info { 'Starting' } @@ -39,25 +38,11 @@ Concurrent.global_io_executor end def start_managers @managers.each do |manager| - Concurrent::Promise.execute { manager.start }.rescue do |ex| - log_manager_failure(ex) - start_soft_shutdown - end + Concurrent::Future.execute { manager.start } end - end - - def start_soft_shutdown - Process.kill('USR1', Process.pid) if @shutdowning.make_true - end - - def log_manager_failure(ex) - return unless ex - - logger.error { "Manager failed: #{ex.message}" } - logger.error { ex.backtrace.join("\n") } unless ex.backtrace.nil? end def initiate_stop logger.info { 'Shutting down' }