mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
Merge pull request #16963 from collectiveidea/activejob-dj
Cleaner queuing of jobs using Delayed Job Conflicts: activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb
This commit is contained in:
commit
f4595e624b
1 changed files with 9 additions and 3 deletions
|
@ -15,16 +15,22 @@ module ActiveJob
|
|||
class DelayedJobAdapter
|
||||
class << self
|
||||
def enqueue(job) #:nodoc:
|
||||
JobWrapper.new.delay(queue: job.queue_name).perform(job.serialize)
|
||||
Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name)
|
||||
end
|
||||
|
||||
def enqueue_at(job, timestamp) #:nodoc:
|
||||
JobWrapper.new.delay(queue: job.queue_name, run_at: Time.at(timestamp)).perform(job.serialize)
|
||||
Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp))
|
||||
end
|
||||
end
|
||||
|
||||
class JobWrapper #:nodoc:
|
||||
def perform(job_data)
|
||||
attr_accessor :job_data
|
||||
|
||||
def initialize(job_data)
|
||||
@job_data = job_data
|
||||
end
|
||||
|
||||
def perform
|
||||
Base.execute(job_data)
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue