diff --git a/lib/resque/worker.rb b/lib/resque/worker.rb index 1ee8beb5e..8e670f28b 100644 --- a/lib/resque/worker.rb +++ b/lib/resque/worker.rb @@ -194,6 +194,7 @@ def work(interval = 5.0, &block) Process.wait(@child) else procline "Processing #{job.queue} since #{Time.now.to_i}" + redis.client.reconnect # New connection for the child perform(job, &block) exit! unless @cant_fork end