From 1c9d82dbf0e743534c5fa9be936eaa46c5b07523 Mon Sep 17 00:00:00 2001 From: Pratik Naik Date: Mon, 6 Apr 2015 13:17:02 -0500 Subject: Add remote connection to talk over internal redis channel --- lib/action_cable/server.rb | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'lib/action_cable/server.rb') diff --git a/lib/action_cable/server.rb b/lib/action_cable/server.rb index 6e9265dc06..51e246c232 100644 --- a/lib/action_cable/server.rb +++ b/lib/action_cable/server.rb @@ -2,12 +2,12 @@ module ActionCable class Server cattr_accessor(:logger, instance_reader: true) { Rails.logger } - attr_accessor :registered_channels, :worker_pool + attr_accessor :registered_channels, :redis_config def initialize(redis_config:, channels:, worker_pool_size: 100, connection: Connection) @redis_config = redis_config @registered_channels = Set.new(channels) - @worker_pool = ActionCable::Worker.pool(size: worker_pool_size) + @worker_pool_size = worker_pool_size @connection_class = connection end @@ -15,9 +15,17 @@ module ActionCable @connection_class.new(self, env).process end + def worker_pool + @worker_pool ||= ActionCable::Worker.pool(size: @worker_pool_size) + end + def pubsub @pubsub ||= EM::Hiredis.connect(@redis_config['url']).pubsub end + def connection_identifiers + @connection_class.identifiers + end + end end -- cgit v1.2.3