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