dj.rb

module Delayed
  class Worker
    def handle_failed_job(job, error)
      ExceptionNotifier.notify(error, :data => {:session => job.attributes})
      job.last_error = error.message + "\n" + error.backtrace.join("\n")
      say "* [JOB] #{name} failed with #{error.class.name}: #{error.message} - #{job.attempts} failed attempts", Logger::ERROR
      reschedule(job)
    end
  end
  
  class PerformableMethod
    def perform
      load(object).send(method, *args.map{|a| load(a)})
    rescue Exception => e
      ExceptionNotifier.notify(e, :data => {:session => {:object => object.inspect, :loaded_object => load(object).inspect, :method => method, :args => args.inspect}})
      raise e
    end
    
    private
    def load(obj)
      if STRING_FORMAT === obj
        $1.constantize.load_for_delayed_job($2)
      else
        obj
      end
    rescue => e
      ExceptionNotifier.notify(e, :data => {:session => {:object => object.inspect, :method => method.inspect, :args => args.inspect}})
      Delayed::Worker.logger.warn "Could not load object for job: #{e.message}"
      raise PerformableMethod::LoadError
    end
  end
end