Contents

require 'bundler/setup'
require 'sequel'
require 'que'
require 'logger'
require 'open-uri'
require 'securerandom'

Que.logger = Logger.new(STDOUT)
Que.logger.level = Logger::INFO
Que.connection = Sequel.connect "postgres://localhost/quewebtest", max_connections: Que.worker_count + 1
Que.migrate!
Que.mode = :async
$stdout.sync = true

class FailJob < Que::Job
  class LameError < StandardError; end

  def run(arg1, arg2)
    raise LameError
  end
end

class SuccessJob < Que::Job
  def run(arg1, arg2)
    sleep 0.5
  end
end

class SlowJob < Que::Job
  def run(arg1, arg2)
    sleep 15
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
que-web-0.8.0	examples/rack/boot.rb
que-web-0.7.2	examples/rack/boot.rb
que-web-0.7.1	examples/rack/boot.rb
que-web-0.7.0	examples/rack/boot.rb
que-web-0.6.3	examples/rack/boot.rb
que-web-0.6.2	examples/rack/boot.rb
que-web-0.6.1	examples/rack/boot.rb
que-web-0.6.0	examples/rack/boot.rb
que-web-0.5.0	examples/rack/boot.rb
que-web-0.4.0	examples/rack/boot.rb
que-web-0.3.2	examples/rack/boot.rb
que-web-0.3.1	examples/rack/boot.rb
que-web-0.3.0	examples/rack/boot.rb
que-web-0.2.2	examples/rack/boot.rb
que-web-0.2.1	examples/rack/boot.rb
que-web-0.2.0	examples/rack/boot.rb
que-web-0.1.0	examples/rack/boot.rb