diff options
| author | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-28 20:38:05 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@loudthinking.com> | 2015-06-29 15:14:52 +0200 |
| commit | a5d6bc0eb527f6cfa61300e70fa9010544240cf9 (patch) | |
| tree | c4bf36c8c83ccb9162c167ac9015c17bdf04a75f /lib/action_cable/server/broadcasting.rb | |
| parent | 8a2af53c8e83cd9258380fad4007e53f8721aa93 (diff) | |
| download | rails-a5d6bc0eb527f6cfa61300e70fa9010544240cf9.tar.gz rails-a5d6bc0eb527f6cfa61300e70fa9010544240cf9.tar.bz2 rails-a5d6bc0eb527f6cfa61300e70fa9010544240cf9.zip | |
Make the remote connection use the broadcaster as well
Diffstat (limited to 'lib/action_cable/server/broadcasting.rb')
| -rw-r--r-- | lib/action_cable/server/broadcasting.rb | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/action_cable/server/broadcasting.rb b/lib/action_cable/server/broadcasting.rb index 691ec1b486..0d591d03e4 100644 --- a/lib/action_cable/server/broadcasting.rb +++ b/lib/action_cable/server/broadcasting.rb @@ -19,8 +19,12 @@ module ActionCable @server, @channel = server, channel end - def broadcast(message, log: true) - server.logger.info "[ActionCable] Broadcasting to #{channel}: #{message}" if log + def broadcast(message) + server.logger.info "[ActionCable] Broadcasting to #{channel}: #{message}" + broadcast_without_logging(message) + end + + def broadcast_without_logging(message) server.redis_for_threads.publish channel, message.to_json end |