Class: ActiveJob::QueueAdapters::TorqueboxAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/torquebox-activejob-adapter.rb

Constant Summary collapse

DEFAULT_QUEUE = 
'/queues/active_job'

Class Method Summary collapse

Class Method Details

.enqueue(job, *args) ⇒ Object 



10
11
12
 
# File 'lib/torquebox-activejob-adapter.rb', line 10

def enqueue(job, *args)
  queue.publish([job, *args])
end

.enqueue_at(job, timestamp, *args) ⇒ Object 



14
15
16
17
18
19
20
 
# 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