class ActiveJob::QueueAdapters::DiscAdapter

Public Class Methods

enqueue(job) click to toggle source
# File lib/active_job/queue_adapters/disc_adapter.rb, line 8
def self.enqueue(job)
  enqueue_at(job, nil)
end
enqueue_at(job, timestamp) click to toggle source
# File lib/active_job/queue_adapters/disc_adapter.rb, line 12
def self.enqueue_at(job, timestamp)
  Disc.disque.push(
    job.queue_name,
    Disc.serialize({
      class: job.class.name,
      arguments: job.arguments
    }),
    Disc.disque_timeout,
    delay: timestamp.nil? ? nil : (timestamp.to_time.to_i - DateTime.now.to_time.to_i)
  )
end