require 'queue_classic' module ActiveJob module QueueAdapters class QueueClassicAdapter class << self def queue(job, *args) qc_queue = QC::Queue.new(job.queue_name) qc_queue.enqueue("ActiveJob::QueueAdapters::QueueClassicAdapter::JobWrapper.perform", job, *args) end def queue_at(job, timestamp, *args) raise NotImplementedError end end class JobWrapper def self.perform(job, *args) job.new.perform *Parameters.deserialize(args) end end end end end