blob: 51891ab07b3740aeeeb9410a8325f5c50c03a993 (
plain) (
tree)
|
|
require 'que'
module ActiveJob
module QueueAdapters
class QueAdapter
class << self
def enqueue(job)
JobWrapper.enqueue job.serialize, queue: job.queue_name
end
def enqueue_at(job, timestamp)
JobWrapper.enqueue job.serialize, queue: job.queue_name, run_at: Time.at(timestamp)
end
end
class JobWrapper < Que::Job
def run(job_data)
Base.execute job_data
end
end
end
end
end
|