module QuJobsManager
Public Instance Methods
can_run?()
click to toggle source
# File activejob/test/support/integration/adapters/qu.rb, line 32 def can_run? begin Qu.backend.connection.client.connect rescue return false end true end
clear_jobs()
click to toggle source
# File activejob/test/support/integration/adapters/qu.rb, line 20 def clear_jobs Qu.clear "integration_tests" end
setup()
click to toggle source
# File activejob/test/support/integration/adapters/qu.rb, line 4 def setup require "qu-quails" require "qu-redis" ActiveJob::Base.queue_adapter = :qu ENV["REDISTOGO_URL"] = "redis://127.0.0.1:6379/12" backend = Qu::Backend::Redis.new backend.namespace = "active_jobs_int_test" Qu.backend = backend Qu.logger = Quails.logger Qu.interval = 0.5 unless can_run? puts "Cannot run integration tests for qu. To be able to run integration tests for qu you need to install and start redis.\n" exit end end
start_workers()
click to toggle source
# File activejob/test/support/integration/adapters/qu.rb, line 24 def start_workers @thread = Thread.new { Qu::Worker.new("integration_tests").start } end
stop_workers()
click to toggle source
# File activejob/test/support/integration/adapters/qu.rb, line 28 def stop_workers @thread.kill end