Remove all the existing connections on redis reconnect

1 files changed, 12 insertions, 1 deletions

diff --git a/lib/action_cable/server.rb b/lib/action_cable/server.rb
index a867d8578f..bfadcee229 100644
--- a/lib/action_cable/server.rb
+++ b/lib/action_cable/server.rb
@@ -24,7 +24,18 @@ module ActionCable
     end
 
     def pubsub
-      @pubsub ||= EM::Hiredis.connect(@redis_config[:url]).pubsub
+      @pubsub ||= redis.pubsub
+    end
+
+    def redis
+      @redis ||= begin
+        redis = EM::Hiredis.connect(@redis_config[:url])
+        redis.on(:reconnected) do
+          logger.info "[ActionCable] Redis reconnected. Closing all the open connections."
+          @connections.map &:close_connection
+        end
+        redis
+      end
     end
 
     def remote_connections