module ArAsyncCounterCache

  def self.resque_job_queue=(sym)
    ArAsyncCounterCache::IncrementCountersJob.class_eval do
      @queue = sym
    end
  end

  class IncrementCountersJob
    @queue = :counter_caches

    # Take advantage of resque-retry if possible.
    begin
      require 'resque-retry'
      require 'active_record/base'
      extend Resque::Plugins::ExponentialBackoff
      @retry_exceptions = [::ActiveRecord::RecordNotFound]
      @backoff_strategy = [0, 10, 100]
    rescue LoadError
    end

    def self.perform(klass_name, id)
      Object.const_get(klass_name).find(id).update_async_counters(:increment)
    end
  end
end