blob: b19a38093fd280a5a7e15d34b288f5fa162e28e9 (
plain) (
tree)
|
|
require 'sucker_punch'
module ActiveJob
module QueueAdapters
class SuckerPunchAdapter
class << self
def enqueue(job)
JobWrapper.new.async.perform job.serialize
end
def enqueue_at(job, timestamp)
raise NotImplementedError
end
end
class JobWrapper
include SuckerPunch::Job
def perform(job_data)
Base.execute job_data
end
end
end
end
end
|