aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/channel/redis.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_cable/channel/redis.rb')
-rw-r--r--lib/action_cable/channel/redis.rb6
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/action_cable/channel/redis.rb b/lib/action_cable/channel/redis.rb
index 197cf03c8e..cbc3512072 100644
--- a/lib/action_cable/channel/redis.rb
+++ b/lib/action_cable/channel/redis.rb
@@ -14,7 +14,7 @@ module ActionCable
@_redis_channels ||= []
@_redis_channels << [ redis_channel, callback ]
- log_info "Subscribing to the redis channel: #{redis_channel}"
+ logger.info "Subscribing to the redis channel: #{redis_channel}"
pubsub.subscribe(redis_channel, &callback)
end
@@ -22,7 +22,7 @@ module ActionCable
def unsubscribe_from_redis_channels
if @_redis_channels
@_redis_channels.each do |channel, callback|
- log_info "Unsubscribing from the redis channel: #{channel}"
+ logger.info "Unsubscribing from the redis channel: #{channel}"
pubsub.unsubscribe_proc(channel, callback)
end
end
@@ -30,7 +30,7 @@ module ActionCable
def default_subscription_callback(channel)
-> (message) do
- log_info "Received a message over the redis channel: #{channel} (#{message})"
+ logger.info "Received a message over the redis channel: #{channel} (#{message})"
broadcast ActiveSupport::JSON.decode(message)
end
end