Активный Job

Объекты Active Job могут быть настроены для работы с различными фреймворками для очередей. Чтобы указать адаптер очереди для использования:

ActiveJob::Base.queue_adapter = :inline

Список поддерживаемых адаптеров можно найти в QueueAdapters.

Объекты Active Job могут быть определены, создав класс, который наследуется от класса ActiveJob::Base. Единственный необходимый метод для реализации — метод «perform».

Для определения объекта Active Job:

class ProcessPhotoJob < ActiveJob::Base
  def perform(photo)
    photo.watermark!('Rails')
    photo.rotate!(90.degrees)
    photo.resize_to_fit!(300, 300)
    photo.upload!
  end
end

Записи, которые передаются, сериализуются/десериализуются с использованием глобального идентификатора. Дополнительную информацию можно найти в разделе Аргументы.

Чтобы добавить задачу в очередь для выполнения, как только система очереди будет свободна:

ProcessPhotoJob.perform_later(photo)

Чтобы добавить задачу в очередь для обработки в определённый момент в будущем:

ProcessPhotoJob.set(wait_until: Date.tomorrow.noon).perform_later(photo)

Дополнительную информацию можно найти в ActiveJob::Core::ClassMethods#set

Задача также может быть обработана немедленно, не отправляя её в очередь:

ProcessPhotoJob.perform_now(photo)

Исключения

• DeserializationError — класс ошибок десериализации.

• SerializationError — класс ошибок сериализации.