Contents

module Resque
  module StuckQueue
    class HeartbeatJob
      class << self

        attr_accessor :redis

        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

      end
    end
  end
end

Version data entries

8 entries across 8 versions & 2 rubygems

Version	Path
resque_stuck_queue-0.5.2	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue_revised-0.5.2	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue_revised-0.5.1	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue-0.5.1	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue-0.4.4	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue-0.4.3	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue-0.4.2	lib/resque_stuck_queue/heartbeat_job.rb
resque_stuck_queue-0.3.9	lib/resque_stuck_queue/heartbeat_job.rb