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