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