use resdis configuration for activity log
This commit is contained in:
parent
d73bf5770d
commit
e90505cfdf
2 changed files with 2 additions and 2 deletions
|
@ -1,7 +1,7 @@
|
||||||
class ActivityLogPublisher
|
class ActivityLogPublisher
|
||||||
|
|
||||||
def initialize
|
def initialize
|
||||||
@redis = Redis.new
|
@redis = RedisConfiguration.new.connection
|
||||||
end
|
end
|
||||||
|
|
||||||
def publish(log_event)
|
def publish(log_event)
|
||||||
|
|
|
@ -3,7 +3,7 @@ require 'redis'
|
||||||
|
|
||||||
class ActivityLogSubscriber
|
class ActivityLogSubscriber
|
||||||
def start
|
def start
|
||||||
redis = Redis.new
|
redis = RedisConfiguration.new.connection
|
||||||
|
|
||||||
redis.subscribe('activity_log') do |on|
|
redis.subscribe('activity_log') do |on|
|
||||||
on.message do |channel, message|
|
on.message do |channel, message|
|
||||||
|
|
Loading…
Reference in a new issue