aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/connection/identifier.rb
diff options
context:
space:
mode:
authorPratik Naik <pratiknaik@gmail.com>2015-04-07 10:11:46 -0500
committerPratik Naik <pratiknaik@gmail.com>2015-04-07 10:11:46 -0500
commit6127d0cda4d60c7b30ee1fb40006da11e04512d0 (patch)
treec6905ea6b5414a64a687dea12cb0ea4631d2e0a1 /lib/action_cable/connection/identifier.rb
parentbdbbe18f3cc527b121bbb2f402898caf4c2fbb15 (diff)
parentfb797ad1f1c3b0d96968c5feef783a2b8fe07eed (diff)
downloadrails-6127d0cda4d60c7b30ee1fb40006da11e04512d0.tar.gz
rails-6127d0cda4d60c7b30ee1fb40006da11e04512d0.tar.bz2
rails-6127d0cda4d60c7b30ee1fb40006da11e04512d0.zip
Merge branch 'connection-management'
Diffstat (limited to 'lib/action_cable/connection/identifier.rb')
-rw-r--r--lib/action_cable/connection/identifier.rb19
1 files changed, 19 insertions, 0 deletions
diff --git a/lib/action_cable/connection/identifier.rb b/lib/action_cable/connection/identifier.rb
new file mode 100644
index 0000000000..9bfd773ab1
--- /dev/null
+++ b/lib/action_cable/connection/identifier.rb
@@ -0,0 +1,19 @@
+module ActionCable
+ module Connection
+ module Identifier
+
+ def internal_redis_channel
+ "action_cable/#{connection_identifier}"
+ end
+
+ def connection_identifier
+ @connection_identifier ||= connection_gid identifiers.map { |id| instance_variable_get("@#{id}")}
+ end
+
+ def connection_gid(ids)
+ ids.map {|o| o.to_global_id.to_s }.sort.join(":")
+ end
+
+ end
+ end
+end