Reestablish redis connection in each new fork

abak-press · Apr 8, 2013 · 10201e4 · 10201e4
1 parent 5274eeb
commit 10201e4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/resque/integration/engine.rb b/lib/resque/integration/engine.rb
@@ -24,6 +24,9 @@ class Engine < Rails::Engine
 
       Resque.redis = [redis.host, redis.port, redis.db].join(':')
       Resque.redis.namespace = redis.namespace
+
+      # Reconnect on each fork
+      Resque.after_fork { Resque.redis.client.reconnect }
     end
 
     initializer 'resque-integration.failure_notifier' do