diff options
author | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-28 21:17:16 +0200 |
---|---|---|
committer | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-29 15:14:52 +0200 |
commit | 5c4f07d34e82310e2ce9029ddaafb6603435da73 (patch) | |
tree | f23f866de9d4d39466841d798c159887e825b31e /lib/action_cable/server | |
parent | c2e2a94306e6b77b0a1dce9b453fbaa04a7f7446 (diff) | |
download | rails-5c4f07d34e82310e2ce9029ddaafb6603435da73.tar.gz rails-5c4f07d34e82310e2ce9029ddaafb6603435da73.tar.bz2 rails-5c4f07d34e82310e2ce9029ddaafb6603435da73.zip |
Introduce Streams as the domain language for the pubsub channels Channels redeliver messages from
Diffstat (limited to 'lib/action_cable/server')
-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 |