Contents

require 'active_job/queue_adapters/inline_adapter'
require 'active_support/core_ext/string/inflections'

module ActiveJob
  # The <tt>ActionJob::QueueAdapter</tt> module is used to load the
  # correct adapter. The default queue adapter is the :inline queue.
  module QueueAdapter #:nodoc:
    extend ActiveSupport::Concern

    # Includes the setter method for changing the active queue adapter.
    module ClassMethods
      mattr_reader(:queue_adapter) { ActiveJob::QueueAdapters::InlineAdapter }

      # Specify the backend queue provider. The default queue adapter
      # is the :inline queue. See QueueAdapters for more
      # information.
      def queue_adapter=(name_or_adapter)
        @@queue_adapter = \
          case name_or_adapter
          when :test
            ActiveJob::QueueAdapters::TestAdapter.new
          when Symbol, String
            load_adapter(name_or_adapter)
          else
            name_or_adapter if name_or_adapter.respond_to?(:enqueue)
          end
      end

      private
        def load_adapter(name)
          "ActiveJob::QueueAdapters::#{name.to_s.camelize}Adapter".constantize
        end
    end
  end
end

Version data entries

44 entries across 43 versions & 8 rubygems

Version	Path
activejob-4.2.11.3	lib/active_job/queue_adapter.rb
activejob-4.2.11.2	lib/active_job/queue_adapter.rb
activejob-4.2.11.1	lib/active_job/queue_adapter.rb
activejob-4.2.11	lib/active_job/queue_adapter.rb
activejob-4.2.10	lib/active_job/queue_adapter.rb
activejob-4.2.10.rc1	lib/active_job/queue_adapter.rb
activejob-4.2.9	lib/active_job/queue_adapter.rb
activejob-4.2.9.rc2	lib/active_job/queue_adapter.rb
activejob-4.2.9.rc1	lib/active_job/queue_adapter.rb
enju_leaf-1.2.1	vendor/bundle/ruby/2.3/gems/activejob-4.2.8/lib/active_job/queue_adapter.rb
activejob-4.2.8	lib/active_job/queue_adapter.rb
activejob-4.2.8.rc1	lib/active_job/queue_adapter.rb
activejob-4.2.7.1	lib/active_job/queue_adapter.rb
activejob-4.2.7	lib/active_job/queue_adapter.rb
activejob-4.2.7.rc1	lib/active_job/queue_adapter.rb
ish_lib_manager-0.0.1	test/dummy/vendor/bundle/ruby/2.3.0/gems/activejob-4.2.6/lib/active_job/queue_adapter.rb
activejob-4.2.6	lib/active_job/queue_adapter.rb
activejob-4.2.6.rc1	lib/active_job/queue_adapter.rb
activejob-4.2.5.2	lib/active_job/queue_adapter.rb
activejob-lock-0.0.2	rails/activejob/lib/active_job/queue_adapter.rb