class ActiveJob::QueueAdapters::SodaAdapter

Public Instance Methods

enqueue(job) click to toggle source
# File lib/soda/extensions/active_job.rb, line 4
def enqueue(job)
  enqueue_at(job, Time.now)
end
enqueue_at(job, ts) click to toggle source
# File lib/soda/extensions/active_job.rb, line 8
def enqueue_at(job, ts)
  job.provider_job_id = ::Soda::Client.push(
    "klass"   => JobWrapper,
    "wrapped" => job.class,
    "queue"   => job.queue_name,
    "delay"   => [0, (ts - Time.now).to_i].max,
    "args"    => [job.serialize],
  )
end