Ruby on Rails 5.2 - ActiveJob::Core

मॉड्यूल ActiveJob :: कोर




ruby

मॉड्यूल ActiveJob :: कोर

सामान्य व्यवहार प्रदान करता है जो ActiveJob::Base से विरासत में मिली प्रत्येक सक्रिय जॉब ऑब्जेक्ट में शामिल किया जाएगा।

पब्लिक क्लास के तरीके

नया (* तर्क) दिखाएँ स्रोत
# File activejob/lib/active_job/core.rb, line 71
def initialize(*arguments)
  @arguments  = arguments
  @job_id     = SecureRandom.uuid
  @queue_name = self.class.queue_name
  @priority   = self.class.priority
  @executions = 0
end

नई नौकरी का उदाहरण बनाता है। उन तर्कों को लेता है जिन्हें प्रदर्शन विधि में पारित किया जाएगा।

सार्वजनिक प्रवृत्ति के तरीके

# File activejob/lib/active_job/core.rb, line 120
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.executions           = job_data["executions"]
  self.locale               = job_data["locale"] || I18n.locale.to_s
end

संग्रहीत कार्य डेटा को वर्तमान उदाहरण में देता है। सीरीज़ से लौटा एक हैश प्राप्त करता है

उदाहरण

class DeliverWebhookJob < ActiveJob::Base
  attr_writer :attempt_number

  def attempt_number
    @attempt_number ||= 0
  end

  def serialize
    super.merge('attempt_number' => attempt_number + 1)
  end

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

  rescue_from(Timeout::Error) do |exception|
    raise exception if attempt_number > 5
    retry_job(wait: 10)
  end
end
क्रमबद्ध करें () दिखाएँ स्रोत
# File activejob/lib/active_job/core.rb, line 81
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_if_needed(arguments),
    "executions" => executions,
    "locale"     => I18n.locale.to_s
  }
end

नौकरी डेटा के साथ एक हैश लौटाता है जो सुरक्षित रूप से कतारबद्ध एडाप्टर को पारित किया जा सकता है।