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