We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 364e155 + 4056a9e commit e0a225aCopy full SHA for e0a225a
actioncable/lib/action_cable/subscription_adapter/redis.rb
@@ -33,7 +33,7 @@ def shutdown
33
end
34
35
def redis_connection_for_subscriptions
36
- ::Redis.new(@server.config.cable)
+ redis_connection
37
38
39
private
@@ -43,10 +43,14 @@ def listener
43
44
def redis_connection_for_broadcasts
45
@redis_connection_for_broadcasts || @server.mutex.synchronize do
46
- @redis_connection_for_broadcasts ||= self.class.redis_connector.call(@server.config.cable)
+ @redis_connection_for_broadcasts ||= redis_connection
47
48
49
50
+ def redis_connection
51
+ self.class.redis_connector.call(@server.config.cable)
52
+ end
53
+
54
class Listener < SubscriberMap
55
def initialize(adapter)
56
super()
0 commit comments