Class: ActiveJob::QueueAdapters::DelayedJobAdapter

Inherits:
AbstractAdapter
  • Object
show all
Defined in:
lib/active_job/queue_adapters/delayed_job_adapter.rb

Overview

Delayed Job adapter for Active Job

To use Delayed Job, set the queue_adapter config to :delayed_job.

Rails.application.config.active_job.queue_adapter = :delayed_job

Defined Under Namespace

Classes: JobWrapper

Instance Method Summary collapse

Instance Method Details

#enqueue(job) ⇒ Object 



11
12
13
14
15
 
# File 'lib/active_job/queue_adapters/delayed_job_adapter.rb', line 11

def enqueue(job)
  delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), :queue => job.queue_name, :priority => job.priority)
  job.provider_job_id = delayed_job.id
  delayed_job
end

#enqueue_at(job, timestamp) ⇒ Object 



17
18
19
20
21
 
# File 'lib/active_job/queue_adapters/delayed_job_adapter.rb', line 17

def enqueue_at(job, timestamp)
  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