Contents

class Marty::Promise < Struct.new(:arg1)
  def log(msg)
    open('/tmp/dj.out', 'a') { |f|
      f.puts msg
    }
  end

  def perform
    log "hello there #{Process.pid} #{arg1}"
    
    raise "oops #{Process.pid}" if arg1 == 5

    sleep 0.2
  end

  def error(job, exc)
    log "Error #{Process.pid} #{job} #{exc}"
  end

  def failure(job)
    log "failure #{Process.pid}, #{job}"
  end

  def before(job)
    log "before #{Process.pid}, #{job}"
  end

  def after(job)
    log "after #{Process.pid}, #{job}"
  end

  def success(job)
    log "success #{Process.pid}, #{job}"
  end

  def max_attempts
    return 1
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
marty-0.5.15	lib/marty/promise.rb~
marty-0.5.14	lib/marty/promise.rb~
marty-0.5.13	lib/marty/promise.rb~
marty-0.5.12	lib/marty/promise.rb~