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