1
0
Fork 0
mirror of https://github.com/rails/rails.git synced 2022-11-09 12:12:34 -05:00
rails--rails/lib/active_job/queue_adapters/que_adapter.rb

20 lines
370 B
Ruby
Raw Normal View History

2014-05-19 14:09:45 -04:00
require 'que'
module ActiveJob
module QueueAdapters
class QueAdapter
class << self
def queue(job, *args)
JobWrapper.enqueue job, *args, queue: job.queue_name
end
end
class JobWrapper < Que::Job
def run(job, *args)
job.new.perform *Parameters.deserialize(args)
end
end
end
end
end