diff --git a/lib/sidekiq/launcher.rb b/lib/sidekiq/launcher.rb index e779f8d6..b6e1fcae 100644 --- a/lib/sidekiq/launcher.rb +++ b/lib/sidekiq/launcher.rb @@ -43,8 +43,8 @@ module Sidekiq watchdog('Launcher#stop') do @done = true Sidekiq::Fetcher.done! - fetcher.async.terminate if fetcher.alive? - poller.async.terminate if poller.alive? + fetcher.terminate if fetcher.alive? + poller.terminate if poller.alive? manager.async.stop(:shutdown => true, :timeout => @options[:timeout]) manager.wait(:shutdown)