aboutsummaryrefslogblamecommitdiffstats
path: root/activejob/test/support/integration/jobs_manager.rb
blob: 78d48e8d9ab3c00e3a3ce1c5909b8a350cd3bcc9 (plain) (tree)
1
2
3
4
5
6




                          
                                                            




















                                                            
class JobsManager
  @@managers = {}
  attr :adapter_name

  def self.current_manager
    @@managers[ENV['AJ_ADAPTER']] ||= new(ENV['AJ_ADAPTER'])
  end

  def initialize(adapter_name)
    @adapter_name = adapter_name
    require_relative "adapters/#{adapter_name}"
    extend "#{adapter_name.camelize}JobsManager".constantize
  end

  def setup
    ActiveJob::Base.queue_adapter = nil
  end

  def clear_jobs
  end

  def start_workers
  end

  def stop_workers
  end
end