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