blob: 7e692298011db22cb6e2281ec90e3bd684b75ce5 (
plain) (
tree)
|
|
require 'qu'
module ActiveJob
module QueueAdapters
class QuAdapter
class << self
def enqueue(job, *args)
Qu::Payload.new(klass: JobWrapper, args: [job, *args], queue: job.queue_name).push
end
def enqueue_at(job, timestamp, *args)
raise NotImplementedError
end
end
class JobWrapper < Qu::Job
def initialize(job, *args)
@job = job
@args = args
end
def perform
@job.new.execute *@args
end
end
end
end
end
|