kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Terminate the poller and the fetcher synchronously.

Browse source
This commit is contained in:
Jonathan Hyman 2014-01-10 11:56:20 -05:00
parent 6cd4e6a96e
commit 8d1eb10f28
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/sidekiq/launcher.rb
View file

@ -43,12 +43,12 @@ module Sidekiq
watchdog('Launcher#stop') do watchdog('Launcher#stop') do
@done = true @done = true
Sidekiq::Fetcher.done! Sidekiq::Fetcher.done!
fetcher.async.terminate if fetcher.alive?
poller.async.terminate if poller.alive?
manager.async.stop(:shutdown => true, :timeout => @options[:timeout]) manager.async.stop(:shutdown => true, :timeout => @options[:timeout])
manager.wait(:shutdown)
fetcher.terminate if fetcher.alive?
poller.terminate if poller.alive?
manager.wait(:shutdown)
# Requeue everything in case there was a worker who grabbed work while stopped # Requeue everything in case there was a worker who grabbed work while stopped
Sidekiq::Fetcher.strategy.bulk_requeue([], @options) Sidekiq::Fetcher.strategy.bulk_requeue([], @options)
end end