diff --git a/app/lib/activity_log_publisher.rb b/app/lib/activity_log_publisher.rb index 0c3d02761..6deeaedec 100644 --- a/app/lib/activity_log_publisher.rb +++ b/app/lib/activity_log_publisher.rb @@ -1,7 +1,7 @@ class ActivityLogPublisher def initialize - @redis = Redis.new + @redis = RedisConfiguration.new.connection end def publish(log_event) diff --git a/lib/activity_log_subscriber.rb b/lib/activity_log_subscriber.rb index f92c0f63b..67dd8b87c 100644 --- a/lib/activity_log_subscriber.rb +++ b/lib/activity_log_subscriber.rb @@ -3,7 +3,7 @@ require 'redis' class ActivityLogSubscriber def start - redis = Redis.new + redis = RedisConfiguration.new.connection redis.subscribe('activity_log') do |on| on.message do |channel, message|