blob: 7b712b9b0377ad45fcfe39100e9b30b8f419cf8e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
require 'em-hiredis'
require 'redis'
module ActionCable
module StorageAdapter
class Redis < Base
# The redis instance used for broadcasting. Not intended for direct user use.
def broadcast
@broadcast ||= ::Redis.new(@server.config.config_opts)
end
def pubsub
redis.pubsub
end
private
# The EventMachine Redis instance used by the pubsub adapter.
def redis
@redis ||= EM::Hiredis.connect(@server.config.config_opts[:url]).tap do |redis|
redis.on(:reconnect_failed) do
@logger.info "[ActionCable] Redis reconnect failed."
# logger.info "[ActionCable] Redis reconnected. Closing all the open connections."
# @connections.map &:close
end
end
end
end
end
end
|