модуль ActiveJob::Core

Предоставляет общее поведение, которое будет включено в каждый объект Active Job, унаследованный от ActiveJob::Base.

Публичные методы класса

# File activejob/lib/active_job/core.rb, line 66
def initialize(*arguments)
  @arguments  = arguments
  @job_id     = SecureRandom.uuid
  @queue_name = self.class.queue_name
  @priority   = self.class.priority
end

Создаёт новый экземпляр задания. Принимает аргументы, которые будут переданы методу perform.

Публичные методы экземпляра

deserialize(job_data) Показать исходный код

# File activejob/lib/active_job/core.rb, line 107
def deserialize(job_data)
  self.job_id               = job_data['job_id']
  self.provider_job_id      = job_data['provider_job_id']
  self.queue_name           = job_data['queue_name']
  self.priority             = job_data['priority']
  self.serialized_arguments = job_data['arguments']
  self.locale               = job_data['locale'] || I18n.locale.to_s
end

Прикрепляет сохранённые данные задания к текущему экземпляру. Получает хэш, возвращённый из serialize

Примеры

class DeliverWebhookJob < ActiveJob::Base
  def serialize
    super.merge('attempt_number' => (@attempt_number || 0) + 1)
  end

  def deserialize(job_data)
    super
    @attempt_number = job_data['attempt_number']
  end

  rescue_from(TimeoutError) do |exception|
    raise exception if @attempt_number > 5
    retry_job(wait: 10)
  end
end

serialize() Показать исходный код

# File activejob/lib/active_job/core.rb, line 75
def serialize
  {
    "job_class"  => self.class.name,
    "job_id"     => job_id,
    "provider_job_id" => provider_job_id,
    "queue_name" => queue_name,
    "priority"   => priority,
    "arguments"  => serialize_arguments(arguments),
    "locale"     => I18n.locale.to_s
  }
end

Возвращает хэш с данными задания, которые можно безопасно передать адаптеру очереди.