diff options
author | Pratik Naik <pratiknaik@gmail.com> | 2015-04-08 18:29:25 -0500 |
---|---|---|
committer | Pratik Naik <pratiknaik@gmail.com> | 2015-04-08 18:29:25 -0500 |
commit | 6d31f64cf65e02fb14f0c1d737ccb90382f91cbe (patch) | |
tree | 254e9608ae5aaf6b3d5361b6f2a014959b9200e7 /lib/action_cable/channel/redis.rb | |
parent | d26f0fa55c63d3a961bc4fae0daf0e1cbde31b34 (diff) | |
download | rails-6d31f64cf65e02fb14f0c1d737ccb90382f91cbe.tar.gz rails-6d31f64cf65e02fb14f0c1d737ccb90382f91cbe.tar.bz2 rails-6d31f64cf65e02fb14f0c1d737ccb90382f91cbe.zip |
Log received redis channel messages
Diffstat (limited to 'lib/action_cable/channel/redis.rb')
-rw-r--r-- | lib/action_cable/channel/redis.rb | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/lib/action_cable/channel/redis.rb b/lib/action_cable/channel/redis.rb index d47e503c51..fda55ec45d 100644 --- a/lib/action_cable/channel/redis.rb +++ b/lib/action_cable/channel/redis.rb @@ -10,7 +10,7 @@ module ActionCable end def subscribe_to(redis_channel, callback = nil) - callback ||= -> (message) { broadcast ActiveSupport::JSON.decode(message) } + callback ||= default_subscription_callback(redis_channel) @_redis_channels ||= [] @_redis_channels << [ redis_channel, callback ] @@ -27,6 +27,14 @@ module ActionCable end end end + + def default_subscription_callback(channel) + -> (message) do + logger.info "[ActionCable] Received a message over the redis channel: #{channel} (#{message})" + broadcast ActiveSupport::JSON.decode(message) + end + end + end end |