blob: 105ccb2b5c6bd991b8329e550d530b7d1fced1e7 (
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
31
|
module ActionCable
module Server
module Broadcasting
def broadcast(broadcasting, message)
broadcaster_for(broadcasting).broadcast(message)
end
def broadcaster_for(broadcasting)
Broadcaster.new(self, broadcasting)
end
def broadcasting_redis
@broadcasting_redis ||= Redis.new(config.redis)
end
private
class Broadcaster
attr_reader :server, :broadcasting
def initialize(server, broadcasting)
@server, @broadcasting = server, broadcasting
end
def broadcast(message)
server.logger.info "[ActionCable] Broadcasting to #{broadcasting}: #{message}"
server.broadcasting_redis.publish broadcasting, message.to_json
end
end
end
end
end
|
