class ActiveJob::QueueAdapters::QuAdapter
Public Class Methods
enqueue(job, *args)
click to toggle source
# File lib/active_job/queue_adapters/qu_adapter.rb, line 7 def enqueue(job, *args) Qu::Payload.new(klass: JobWrapper, args: [job.serialize]).tap do |payload| payload.instance_variable_set(:@queue, job.queue_name) end.push end
enqueue_at(job, timestamp, *args)
click to toggle source
# File lib/active_job/queue_adapters/qu_adapter.rb, line 13 def enqueue_at(job, timestamp, *args) raise NotImplementedError end