- Defined in:
Qu adapter for Active Job
Qu is a Ruby library for queuing and processing background jobs. It is heavily inspired by delayed_job and Resque. Qu was created to overcome some shortcomings in the existing queuing libraries. The advantages of Qu are: Multiple backends (redis, mongo), jobs are requeued when worker is killed, resque-like API.
Read more about Qu here.
To use Qu set the queue_adapter config to
..config.active_job.queue_adapter = :qu
Defined Under Namespace
Instance Method Summary collapse
Instance Method Details
#enqueue(job, *args) ⇒
19 20 21 22 23 24 25 26 27
# File 'activejob/lib/active_job/queue_adapters/qu_adapter.rb', line 19 def enqueue(job, *args) #:nodoc: qu_job = Qu::Payload.new(klass: , args: [job.serialize]).tap do |payload| payload.instance_variable_set(:@queue, job.queue_name) end.push # qu_job can be nil depending on the configured backend job.provider_job_id = qu_job.id unless qu_job.nil? qu_job end
#enqueue_at(job, timestamp, *args) ⇒
29 30 31
# File 'activejob/lib/active_job/queue_adapters/qu_adapter.rb', line 29 def enqueue_at(job, , *args) #:nodoc: raise NotImplementedError, "This queueing backend does not support scheduling jobs. To see what features are supported go to http://api.rubyonrails.org/classes/ActiveJob/QueueAdapters.html" end