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