126 lines
4.6 KiB
Ruby
126 lines
4.6 KiB
Ruby
module ActiveJob
|
|
# == Active Job adapters
|
|
#
|
|
# Active Job has adapters for the following queueing backends:
|
|
#
|
|
# * {Backburner}[https://github.com/nesquena/backburner]
|
|
# * {Delayed Job}[https://github.com/collectiveidea/delayed_job]
|
|
# * {Qu}[https://github.com/bkeepers/qu]
|
|
# * {Que}[https://github.com/chanks/que]
|
|
# * {queue_classic}[https://github.com/QueueClassic/queue_classic]
|
|
# * {Resque 1.x}[https://github.com/resque/resque/tree/1-x-stable]
|
|
# * {Sidekiq}[http://sidekiq.org]
|
|
# * {Sneakers}[https://github.com/jondot/sneakers]
|
|
# * {Sucker Punch}[https://github.com/brandonhilkert/sucker_punch]
|
|
#
|
|
# === Backends Features
|
|
#
|
|
# | | Async | Queues | Delayed | Priorities | Timeout | Retries |
|
|
# |-------------------|-------|--------|-----------|------------|---------|---------|
|
|
# | Backburner | Yes | Yes | Yes | Yes | Job | Global |
|
|
# | Delayed Job | Yes | Yes | Yes | Job | Global | Global |
|
|
# | Qu | Yes | Yes | No | No | No | Global |
|
|
# | Que | Yes | Yes | Yes | Job | No | Job |
|
|
# | queue_classic | Yes | Yes | No* | No | No | No |
|
|
# | Resque | Yes | Yes | Yes (Gem) | Queue | Global | Yes |
|
|
# | Sidekiq | Yes | Yes | Yes | Queue | No | Job |
|
|
# | Sneakers | Yes | Yes | No | Queue | Queue | No |
|
|
# | Sucker Punch | Yes | Yes | No | No | No | No |
|
|
# | Active Job Inline | No | Yes | N/A | N/A | N/A | N/A |
|
|
# | Active Job | Yes | Yes | Yes | No | No | No |
|
|
#
|
|
# ==== Async
|
|
#
|
|
# Yes: The Queue Adapter runs the jobs in a separate or forked process.
|
|
#
|
|
# No: The job is run in the same process.
|
|
#
|
|
# ==== Queues
|
|
#
|
|
# Yes: Jobs may set which queue they are run in with queue_as or by using the set
|
|
# method.
|
|
#
|
|
# ==== Delayed
|
|
#
|
|
# Yes: The adapter will run the job in the future through perform_later.
|
|
#
|
|
# (Gem): An additional gem is required to use perform_later with this adapter.
|
|
#
|
|
# No: The adapter will run jobs at the next opportunity and cannot use perform_later.
|
|
#
|
|
# N/A: The adapter does not support queueing.
|
|
#
|
|
# NOTE:
|
|
# queue_classic does not support job scheduling.
|
|
# However, you can use the queue_classic-later gem.
|
|
# See the documentation for ActiveJob::QueueAdapters::QueueClassicAdapter.
|
|
#
|
|
# ==== Priorities
|
|
#
|
|
# The order in which jobs are processed can be configured differently depending
|
|
# on the adapter.
|
|
#
|
|
# Job: Any class inheriting from the adapter may set the priority on the job
|
|
# object relative to other jobs.
|
|
#
|
|
# Queue: The adapter can set the priority for job queues, when setting a queue
|
|
# with Active Job this will be respected.
|
|
#
|
|
# Yes: Allows the priority to be set on the job object, at the queue level or
|
|
# as default configuration option.
|
|
#
|
|
# No: Does not allow the priority of jobs to be configured.
|
|
#
|
|
# N/A: The adapter does not support queueing, and therefore sorting them.
|
|
#
|
|
# ==== Timeout
|
|
#
|
|
# When a job will stop after the allotted time.
|
|
#
|
|
# Job: The timeout can be set for each instance of the job class.
|
|
#
|
|
# Queue: The timeout is set for all jobs on the queue.
|
|
#
|
|
# Global: The adapter is configured that all jobs have a maximum run time.
|
|
#
|
|
# N/A: This adapter does not run in a separate process, and therefore timeout
|
|
# is unsupported.
|
|
#
|
|
# ==== Retries
|
|
#
|
|
# Job: The number of retries can be set per instance of the job class.
|
|
#
|
|
# Yes: The Number of retries can be configured globally, for each instance or
|
|
# on the queue. This adapter may also present failed instances of the job class
|
|
# that can be restarted.
|
|
#
|
|
# Global: The adapter has a global number of retries.
|
|
#
|
|
# N/A: The adapter does not run in a separate process, and therefore doesn't
|
|
# support retries.
|
|
module QueueAdapters
|
|
extend ActiveSupport::Autoload
|
|
|
|
autoload :InlineAdapter
|
|
autoload :BackburnerAdapter
|
|
autoload :DelayedJobAdapter
|
|
autoload :QuAdapter
|
|
autoload :QueAdapter
|
|
autoload :QueueClassicAdapter
|
|
autoload :ResqueAdapter
|
|
autoload :SidekiqAdapter
|
|
autoload :SneakersAdapter
|
|
autoload :SuckerPunchAdapter
|
|
autoload :TestAdapter
|
|
|
|
ADAPTER = 'Adapter'.freeze
|
|
private_constant :ADAPTER
|
|
|
|
class << self
|
|
def lookup(name)
|
|
const_get(name.to_s.camelize << ADAPTER)
|
|
end
|
|
end
|
|
end
|
|
end
|