Contents

class ReleaseJob < Quebert::Job
  def perform
    release!
  end
end

class DeleteJob < Quebert::Job
  def perform
    delete!
  end
end

class BuryJob < Quebert::Job
  def perform
    bury!
  end
end

class TimeoutJob < Quebert::Job
  def perform!
    # 1 second TTR
    @ttr = 1
    super
  end

  def perform
    # 10 second task should definitely raise a Job::Timeout exception
    sleep(10)
  end
end

class Adder < Quebert::Job
  def perform(*args)
    args.inject(0){|sum, n| sum = sum + n}
  end
end

class Exceptional < Quebert::Job
  def perform
    raise Exception
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
quebert-1.0.1	spec/support/jobs.rb
quebert-1.0.0	spec/support/jobs.rb
quebert-0.0.9	spec/support/jobs.rb