aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/server
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_cable/server')
-rw-r--r--lib/action_cable/server/broadcasting.rb18
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