lib/plezi/common/redis.rb in plezi-0.10.12 vs lib/plezi/common/redis.rb in plezi-0.10.13

- old
+ new

@@ -19,10 +19,10 @@ @redis_uri ||= URI.parse(ENV['PL_REDIS_URL']) @redis ||= Redis.new(host: @redis_uri.host, port: @redis_uri.port, password: @redis_uri.password) raise "Redis connction failed for: #{ENV['PL_REDIS_URL']}" unless @redis @redis_sub_thread = Thread.new do begin - Redis.new(host: @redis_uri.host, port: @redis_uri.port, password: @redis_uri.password).subscribe(Plezi::Settings.redis_channel_name) do |on| + Redis.new(host: @redis_uri.host, port: @redis_uri.port, password: @redis_uri.password).subscribe(Plezi::Settings.redis_channel_name, Plezi::Settings.uuid) do |on| on.message do |channel, msg| begin data = YAML.load(msg) next if data[:server] == Plezi::Settings.uuid if data[:target]