1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
require 'sneakers' module ActiveJob module QueueAdapters class SneakersAdapter class << self def queue(job, *args) JobWrapper.enqueue([job, *args]) end end class JobWrapper include Sneakers::Worker self.from_queue("queue", {}) def work(job, *args) job.new.perform *Parameters.deserialize(args) end end end end end