Contents

class JobsManager
  @@managers = {}
  attr :adapter_name

  def self.current_manager
    @@managers[ENV['AJADAPTER']] ||= new(ENV['AJADAPTER'])
  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

Version data entries

15 entries across 15 versions & 2 rubygems

Version	Path
activejob-retry-0.6.3	test/support/integration/jobs_manager.rb
activejob-retry-0.6.2	test/support/integration/jobs_manager.rb
activejob-retry-0.6.1	test/support/integration/jobs_manager.rb
activejob-retry-0.6.0	test/support/integration/jobs_manager.rb
activejob-lock-0.0.2	rails/activejob/test/support/integration/jobs_manager.rb
activejob-retry-0.5.1	test/support/integration/jobs_manager.rb
activejob-retry-0.5.0	test/support/integration/jobs_manager.rb
activejob-retry-0.4.2	test/support/integration/jobs_manager.rb
activejob-retry-0.4.1	test/support/integration/jobs_manager.rb
activejob-lock-0.0.1	rails/activejob/test/support/integration/jobs_manager.rb
activejob-retry-0.4.0	test/support/integration/jobs_manager.rb
activejob-retry-0.3.1	test/support/integration/jobs_manager.rb
activejob-retry-0.3.0	test/support/integration/jobs_manager.rb
activejob-retry-0.2.0	test/support/integration/jobs_manager.rb
activejob-retry-0.1.1	test/support/integration/jobs_manager.rb