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]