Sha256: d89470b77fa55966f2232a0eb08f33db61e8d835f43af92adae235fcabf9610e

Contents?: true

Size: 704 Bytes

Versions: 4

Compression:

Stored size: 704 Bytes

Contents

$worker_test_count = 0
$worker_success = false

class TestPlainJob
  def self.queue; "test-plain"; end
  def self.perform(x, y); $worker_test_count += x + y + 1; end
end

class TestJob
  include Backburner::Queue
  queue_priority :medium
  def self.perform(x, y); $worker_test_count += x + y; end
end

class TestFailJob
  include Backburner::Queue
  def self.perform(x, y); raise RuntimeError; end
end

class TestRetryJob
  include Backburner::Queue
  def self.perform(x, y)
    $worker_test_count += 1
    raise RuntimeError unless $worker_test_count > 2
    $worker_success = true
  end
end

class TestAsyncJob
  include Backburner::Performable
  def self.foo(x, y); $worker_test_count = x * y; end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
backburner-0.4.3 test/fixtures/test_jobs.rb
backburner-0.4.2 test/fixtures/test_jobs.rb
backburner-0.4.1 test/fixtures/test_jobs.rb
backburner-0.4.0 test/fixtures/test_jobs.rb