module BackburnerJobsManager

Public Instance Methods

can_run?() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 31
def can_run?
  begin
    @worker = Backburner::Worker.new
  rescue
    return false
  end
  true
end
clear_jobs() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 15
def clear_jobs
  tube.clear
end
setup() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 4
def setup
  ActiveJob::Base.queue_adapter = :backburner
  Backburner.configure do |config|
    config.logger = Quails.logger
  end
  unless can_run?
    puts "Cannot run integration tests for backburner. To be able to run integration tests for backburner you need to install and start beanstalkd.\n"
    exit
  end
end
start_workers() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 19
def start_workers
  @thread = Thread.new { Backburner.work "integration-tests" } # backburner dasherizes the queue name
end
stop_workers() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 23
def stop_workers
  @thread.kill
end
tube() click to toggle source
# File activejob/test/support/integration/adapters/backburner.rb, line 27
def tube
  @tube ||= Beaneater::Tube.new(@worker.connection, "backburner.worker.queue.integration-tests") # backburner dasherizes the queue name
end