diff --git a/lib/resque/integration/tasks/hooks.rake b/lib/resque/integration/tasks/hooks.rake index 129fcd0..82cc0d9 100644 --- a/lib/resque/integration/tasks/hooks.rake +++ b/lib/resque/integration/tasks/hooks.rake @@ -26,7 +26,12 @@ namespace :resque do end Resque.before_fork do - Resque.redis.client.disconnect + client = if Gem::Version.new(::Redis::VERSION) < Gem::Version.new('4') + Resque.redis.client + else + Resque.redis._client + end + client.disconnect ActiveRecord::Base.connection_handler.clear_all_connections! end @@ -36,7 +41,12 @@ namespace :resque do ActiveRecord::Base.establish_connection - Resque.redis.client.connect + client = if Gem::Version.new(::Redis::VERSION) < Gem::Version.new('4') + Resque.redis.client + else + Resque.redis._client + end + client.connect end # Support for resque-multi-job-forks