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