class ActiveJob::QueueAdapters::TorqueboxAdapter

Constants

DEFAULT_QUEUE

Public Class Methods

enqueue(job, *args) click to toggle source
# File lib/torquebox-activejob-adapter.rb, line 10
def enqueue(job, *args)
  queue.publish([job, *args])
end
enqueue_at(job, timestamp, *args) click to toggle source
# File lib/torquebox-activejob-adapter.rb, line 14
def enqueue_at(job, timestamp, *args)
  time = Time.at(timestamp)
  Rails.logger.debug("ENQUEUE_AT: #{time}")
  queue.publish([job, *args], {
      scheduled: time
  })
end

Private Class Methods

queue() click to toggle source
# File lib/torquebox-activejob-adapter.rb, line 23
def queue
  TorqueBox.fetch(DEFAULT_QUEUE)
end