blob: 2e8a64aa87eace7ce2348feb00f6e6000080cba2 (
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 #:nodoc:
def run(job_data)
Base.execute job_data
end
end
end
end
end
|