mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Merge pull request #1423 from mperham/feature/fetcher-join
Terminate the poller and the fetcher synchronously.
This commit is contained in:
commit
c89cca6aff
1 changed files with 2 additions and 2 deletions
|
@ -43,8 +43,8 @@ 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?
|
fetcher.terminate if fetcher.alive?
|
||||||
poller.async.terminate if poller.alive?
|
poller.terminate if poller.alive?
|
||||||
|
|
||||||
manager.async.stop(:shutdown => true, :timeout => @options[:timeout])
|
manager.async.stop(:shutdown => true, :timeout => @options[:timeout])
|
||||||
manager.wait(:shutdown)
|
manager.wait(:shutdown)
|
||||||
|
|
Loading…
Add table
Reference in a new issue