class Barrage::Generators::RedisWorkerId::Finalizer
Public Class Methods
new(data)
click to toggle source
# File lib/barrage/generators/redis_worker_id.rb, line 42 def initialize(data) @pid = $$ @data = data end
Public Instance Methods
call(*args)
click to toggle source
# File lib/barrage/generators/redis_worker_id.rb, line 47 def call(*args) return if @pid != $$ redis, worker_id, real_ttl = *@data if redis.is_a?(Redis) and redis.connected? redis.del("barrage:worker:#{worker_id}") if real_ttl > Time.now.to_i redis._client.disconnect end end