Sha256: 30de064e394d2a4135ea5d8524583bfd371571f492f8e62f6327e91fb03d1fa6
Contents?: true
Size: 1.27 KB
Versions: 15
Compression:
Stored size: 1.27 KB
Contents
module ResqueJobsManager
def setup
ActiveJob::Base.queue_adapter = :resque
Resque.redis = Redis::Namespace.new 'active_jobs_int_test', redis: Redis.connect(url: "redis://127.0.0.1:6379/12", :thread_safe => true)
Resque.logger = Rails.logger
unless can_run?
puts "Cannot run integration tests for resque. To be able to run integration tests for resque you need to install and start redis.\n"
exit
end
end
def clear_jobs
Resque.queues.each { |queue_name| Resque.redis.del "queue:#{queue_name}" }
Resque.redis.keys("delayed:*").each { |key| Resque.redis.del "#{key}" }
Resque.redis.del "delayed_queue_schedule"
end
def start_workers
@resque_thread = Thread.new do
w = Resque::Worker.new("integration_tests")
w.term_child = true
w.work(0.5)
end
@scheduler_thread = Thread.new do
Resque::Scheduler.configure do |c|
c.poll_sleep_amount = 0.5
c.dynamic = true
c.quiet = true
c.logfile = nil
end
Resque::Scheduler.master_lock.release!
Resque::Scheduler.run
end
end
def stop_workers
@resque_thread.kill
@scheduler_thread.kill
end
def can_run?
begin
Resque.redis.client.connect
rescue
return false
end
true
end
end
Version data entries
15 entries across 15 versions & 2 rubygems