Class: ActiveJob::QueueAdapters::QuAdapter
- Inherits:
-
Object
- Object
- ActiveJob::QueueAdapters::QuAdapter
- Defined in:
- lib/active_job/queue_adapters/qu_adapter.rb
Overview
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 :qu
.
Rails.application.config.active_job.queue_adapter = :qu
Defined Under Namespace
Classes: JobWrapper
Instance Method Summary collapse
-
#enqueue(job, *args) ⇒ Object
:nodoc:.
-
#enqueue_at(job, timestamp, *args) ⇒ Object
:nodoc:.
Instance Method Details
#enqueue(job, *args) ⇒ Object
:nodoc:
21 22 23 24 25 26 27 28 29 |
# File 'lib/active_job/queue_adapters/qu_adapter.rb', line 21 def enqueue(job, *args) #:nodoc: qu_job = Qu::Payload.new(klass: JobWrapper, 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) ⇒ Object
:nodoc:
31 32 33 |
# File 'lib/active_job/queue_adapters/qu_adapter.rb', line 31 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 |