class Delayed::ActiveJobAdapter

Public Instance Methods

enqueue(job) click to toggle source
# File lib/delayed/active_job_adapter.rb, line 3
def enqueue(job)
  _enqueue(job)
end
enqueue_at(job, timestamp) click to toggle source
# File lib/delayed/active_job_adapter.rb, line 7
def enqueue_at(job, timestamp)
  _enqueue(job, run_at: Time.at(timestamp)) # rubocop:disable Rails/TimeZone
end

Private Instance Methods

_enqueue(job, opts = {}) click to toggle source
# File lib/delayed/active_job_adapter.rb, line 13
def _enqueue(job, opts = {})
  opts.merge!({ queue: job.queue_name, priority: job.priority }.compact)
    .merge!(job.provider_attributes || {})

  Delayed::Job.enqueue(JobWrapper.new(job.serialize), opts).tap do |dj|
    job.provider_job_id = dj.id
  end
end