diff options
| author | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-21 21:08:20 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-21 21:08:20 +0200 |
| commit | 81ae9ee32162ececbd70664b2821e7c636eaed8b (patch) | |
| tree | 3776838ed43fb8f52b2b7b8443f563f79dad6322 /lib/action_cable/connection/internal_channel.rb | |
| parent | cc5ad6a65729a7c2c922e230c68b137762b8b127 (diff) | |
| download | rails-81ae9ee32162ececbd70664b2821e7c636eaed8b.tar.gz rails-81ae9ee32162ececbd70664b2821e7c636eaed8b.tar.bz2 rails-81ae9ee32162ececbd70664b2821e7c636eaed8b.zip | |
Consolidate all identification logic in a single concern
Diffstat (limited to 'lib/action_cable/connection/internal_channel.rb')
| -rw-r--r-- | lib/action_cable/connection/internal_channel.rb | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/action_cable/connection/internal_channel.rb b/lib/action_cable/connection/internal_channel.rb index 3a11bcaf7b..55dfc72777 100644 --- a/lib/action_cable/connection/internal_channel.rb +++ b/lib/action_cable/connection/internal_channel.rb @@ -3,6 +3,10 @@ module ActionCable module InternalChannel extend ActiveSupport::Concern + def internal_redis_channel + "action_cable/#{connection_identifier}" + end + def subscribe_to_internal_channel if connection_identifier.present? callback = -> (message) { process_internal_message(message) } |