class Resque::StuckQueue::HeartbeatJob

Attributes

redis[RW]

Public Class Methods

perform(*args) click to toggle source
# File lib/resque_stuck_queue/heartbeat_job.rb, line 8
def perform(*args)
  keyname,host,port,namespace,new_time = *args
  # if set by config[:redis] earlier before loading this lib.
  @redis = Resque::StuckQueue.redis || Redis::Namespace.new(namespace, :redis => Redis.new(:host => host, :port => port))
  @redis.set(keyname, new_time)
  Resque::StuckQueue.logger.info "successfully updated key #{keyname} to #{new_time} at #{Time.now} for #{@redis.inspect}"
end