1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
require 'queue_classic' module ActiveJob module QueueAdapters class QueueClassicAdapter class << self def enqueue(job, *args) QC::Queue.new(job.queue_name).enqueue("#{JobWrapper.name}.perform", job, *args) end def enqueue_at(job, timestamp, *args) raise NotImplementedError end end class JobWrapper def self.perform(job, *args) job.new.execute *args end end end end end