Sha256: 4eabfa714e091a246267ee75607df1aa9b2fb9e82ed9fd0aa9de9e66d6fd2c50

Contents?: true

Size: 572 Bytes

Versions: 3

Compression:

Stored size: 572 Bytes

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 initialize
    super
    @ttr = 1
  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
    fail "Exceptional"
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
quebert-3.3.0 spec/support/jobs.rb
quebert-3.2.1 spec/support/jobs.rb
quebert-3.2.0 spec/support/jobs.rb