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