class ActiveJob::QueueAdapters::BarbequeAdapter
Public Class Methods
enqueue(job)
click to toggle source
Interface for ActiveJob
4.2
# File lib/active_job/queue_adapters/barbeque_adapter.rb, line 15 def enqueue(job) execution = BarbequeClient.enqueue( job: job.class.to_s, message: ActiveJob::Arguments.serialize(job.arguments), queue: job.queue_name, ) job.job_id = execution.message_id end
enqueue_at(job, timestamp)
click to toggle source
# File lib/active_job/queue_adapters/barbeque_adapter.rb, line 24 def enqueue_at(job, timestamp) delay_seconds = (timestamp - Time.now.to_f).round execution = BarbequeClient.enqueue( job: job.class.to_s, message: ActiveJob::Arguments.serialize(job.arguments), queue: job.queue_name, delay_seconds: delay_seconds, ) job.job_id = execution.message_id end
Public Instance Methods
enqueue(job)
click to toggle source
Interface for ActiveJob
5.0
# File lib/active_job/queue_adapters/barbeque_adapter.rb, line 5 def enqueue(job) BarbequeAdapter.enqueue(job) end
enqueue_at(job, timestamp)
click to toggle source
# File lib/active_job/queue_adapters/barbeque_adapter.rb, line 9 def enqueue_at(job, timestamp) BarbequeAdapter.enqueue_at(job, timestamp) end