Contents

$:.unshift "lib"
require 'backburner'

$values = []

# Define ruby job
class TestJob
  include Backburner::Queue
  queue "test-job"

  def self.perform(value)
    puts "[TestJob] Running perform with args: [#{value}]"
    $values << value
    puts "#{$values.size} total jobs processed"
  end
end

# Configure Backburner
Backburner.configure do |config|
  config.beanstalk_url = "beanstalk://127.0.0.1"
  config.tube_namespace = "demo.production"
end

# Enqueue tasks
1.upto(1000) do |i|
  Backburner.enqueue TestJob, i
end

# Work tasks using threads_on_fork worker
# twitter tube will have 10 threads, garbage after 1000 executions and retry jobs 1 times.
Backburner.work("test-job:10:100:1", :worker => Backburner::Workers::ThreadsOnFork)

Version data entries

66 entries across 66 versions & 2 rubygems

Version	Path
backburner-allq-1.0.50	examples/stress.rb
backburner-allq-1.0.49	examples/stress.rb
backburner-allq-1.0.48	examples/stress.rb
backburner-1.6.1	examples/stress.rb
backburner-allq-1.0.47	examples/stress.rb
backburner-allq-1.0.46	examples/stress.rb
backburner-allq-1.0.45	examples/stress.rb
backburner-allq-1.0.44	examples/stress.rb
backburner-allq-1.0.40	examples/stress.rb
backburner-allq-1.0.39	examples/stress.rb
backburner-allq-1.0.38	examples/stress.rb
backburner-allq-1.0.37	examples/stress.rb
backburner-allq-1.0.36	examples/stress.rb
backburner-1.6.0	examples/stress.rb
backburner-allq-1.0.35	examples/stress.rb
backburner-allq-1.0.34	examples/stress.rb
backburner-allq-1.0.33	examples/stress.rb
backburner-allq-1.0.32	examples/stress.rb
backburner-allq-1.0.31	examples/stress.rb
backburner-allq-1.0.29	examples/stress.rb