aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/server/broadcasting.rb
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2015-06-28 20:42:49 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2015-06-29 15:14:52 +0200
commitc2e2a94306e6b77b0a1dce9b453fbaa04a7f7446 (patch)
tree1da6578b6ccecf45960f7dde4217b6149c37fd72 /lib/action_cable/server/broadcasting.rb
parent3e693e19c4ed3ad3fdb861d0c0d4c3abe118479c (diff)
downloadrails-c2e2a94306e6b77b0a1dce9b453fbaa04a7f7446.tar.gz
rails-c2e2a94306e6b77b0a1dce9b453fbaa04a7f7446.tar.bz2
rails-c2e2a94306e6b77b0a1dce9b453fbaa04a7f7446.zip
Rejig for what's used
Diffstat (limited to 'lib/action_cable/server/broadcasting.rb')
-rw-r--r--lib/action_cable/server/broadcasting.rb15
1 files changed, 7 insertions, 8 deletions
diff --git a/lib/action_cable/server/broadcasting.rb b/lib/action_cable/server/broadcasting.rb
index 0d591d03e4..3fbaa05039 100644
--- a/lib/action_cable/server/broadcasting.rb
+++ b/lib/action_cable/server/broadcasting.rb
@@ -9,12 +9,14 @@ module ActionCable
Broadcaster.new(self, channel)
end
- private
- def redis_for_threads
- @redis_for_threads ||= Redis.new(redis_config)
- end
+ def broadcasting_redis
+ @broadcasting_redis ||= Redis.new(redis_config)
+ end
+ private
class Broadcaster
+ attr_reader :server, :channel
+
def initialize(server, channel)
@server, @channel = server, channel
end
@@ -25,11 +27,8 @@ module ActionCable
end
def broadcast_without_logging(message)
- server.redis_for_threads.publish channel, message.to_json
+ server.broadcasting_redis.publish channel, message.to_json
end
-
- private
- attr_reader :server, :channel
end
end
end