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/queue_classic_adapter.rb
2014-05-22 20:37:06 +02:00

23 lines
487 B
Ruby

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