lib/plezi/common/redis.rb in plezi-0.12.14 vs lib/plezi/common/redis.rb in plezi-0.12.15
- old
+ new
@@ -9,14 +9,14 @@
def inner_init_redis
return false unless ENV['PL_REDIS_URL'] && defined?(::Redis)
@redis_locker.synchronize do
return @redis if (@redis_sub_thread && @redis_sub_thread.alive?) && @redis # repeat the test once syncing is done.
@redis.quit if @redis
- @redis = ::Redis.new(ENV['PL_REDIS_URL'])
+ @redis = ::Redis.new(url: ENV['PL_REDIS_URL'])
raise "Redis connction failed for: #{ENV['PL_REDIS_URL']}" unless @redis
@redis_sub_thread = Thread.new do
begin
- ::Redis.new(ENV['PL_REDIS_URL']).subscribe(Plezi::Settings.redis_channel_name, Plezi::Settings.uuid) do |on|
+ ::Redis.new(url: ENV['PL_REDIS_URL']).subscribe(Plezi::Settings.redis_channel_name, Plezi::Settings.uuid) do |on|
on.message do |channel, msg|
::Plezi::Base::WSObject.forward_message ::Plezi::Base::WSObject.translate_message(msg)
end
end
rescue => e