Method: ActiveJob::QueueAdapters::DelayedJobAdapter#enqueue_at

Defined in:
activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb

#enqueue_at(job, timestamp) ⇒ Object

:nodoc:



25
26
27
28
29
 
# File 'activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb', line 25

def enqueue_at(job, timestamp) # :nodoc:
  delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, priority: job.priority, run_at: Time.at(timestamp))
  job.provider_job_id = delayed_job.id
  delayed_job
end