diff options
Diffstat (limited to 'lib/action_cable/server/broadcasting.rb')
-rw-r--r-- | lib/action_cable/server/broadcasting.rb | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/lib/action_cable/server/broadcasting.rb b/lib/action_cable/server/broadcasting.rb index 3fbaa05039..868d418ece 100644 --- a/lib/action_cable/server/broadcasting.rb +++ b/lib/action_cable/server/broadcasting.rb @@ -1,12 +1,12 @@ module ActionCable module Server module Broadcasting - def broadcast(channel, message) - broadcaster_for(channel).broadcast(message) + def broadcast(broadcasting, message) + broadcaster_for(broadcasting).broadcast(message) end - def broadcaster_for(channel) - Broadcaster.new(self, channel) + def broadcaster_for(broadcasting) + Broadcaster.new(self, broadcasting) end def broadcasting_redis @@ -15,19 +15,19 @@ module ActionCable private class Broadcaster - attr_reader :server, :channel + attr_reader :server, :broadcasting - def initialize(server, channel) - @server, @channel = server, channel + def initialize(server, broadcasting) + @server, @broadcasting = server, broadcasting end def broadcast(message) - server.logger.info "[ActionCable] Broadcasting to #{channel}: #{message}" + server.logger.info "[ActionCable] Broadcasting to #{broadcasting}: #{message}" broadcast_without_logging(message) end def broadcast_without_logging(message) - server.broadcasting_redis.publish channel, message.to_json + server.broadcasting_redis.publish broadcasting, message.to_json end end end |