Active 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

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

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

ProcessPhotoJob.perform_later(photo)

Для добавления задания в очередь для обработки в какой-то момент в будущем:

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

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

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

ProcessPhotoJob.perform_now(photo)

Исключения

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

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