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