diff options
| author | Alberto Almagro <alberto.almagro@rakuten.com> | 2018-03-19 21:25:39 +0100 |
|---|---|---|
| committer | Alberto Almagro <alberto.almagro@rakuten.com> | 2018-03-19 21:27:16 +0100 |
| commit | 6ef720791d6532a107f4777edfe1d708b6b9c068 (patch) | |
| tree | c6ce9a6aabe6654af03384bd8de7b4a1b71ef3b1 /activejob/lib/active_job/queue_adapters/qu_adapter.rb | |
| parent | 538463bce782e58ea72d130315cc510dab50777d (diff) | |
| download | rails-6ef720791d6532a107f4777edfe1d708b6b9c068.tar.gz rails-6ef720791d6532a107f4777edfe1d708b6b9c068.tar.bz2 rails-6ef720791d6532a107f4777edfe1d708b6b9c068.zip | |
Remove support for Qu gem.
Reasons are that the Qu gem wasn't compatible since Rails 5.1,
gem development was stopped in 2014 and maintainers have
confirmed its demise. See issue #32273
Diffstat (limited to 'activejob/lib/active_job/queue_adapters/qu_adapter.rb')
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/qu_adapter.rb | 46 |
1 files changed, 0 insertions, 46 deletions
diff --git a/activejob/lib/active_job/queue_adapters/qu_adapter.rb b/activejob/lib/active_job/queue_adapters/qu_adapter.rb deleted file mode 100644 index bd7003e177..0000000000 --- a/activejob/lib/active_job/queue_adapters/qu_adapter.rb +++ /dev/null @@ -1,46 +0,0 @@ -# frozen_string_literal: true - -require "qu" - -module ActiveJob - module QueueAdapters - # == 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}[https://github.com/bkeepers/qu]. - # - # To use Qu set the queue_adapter config to +:qu+. - # - # Rails.application.config.active_job.queue_adapter = :qu - class QuAdapter - 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 - - def enqueue_at(job, timestamp, *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 - - class JobWrapper < Qu::Job #:nodoc: - def initialize(job_data) - @job_data = job_data - end - - def perform - Base.execute @job_data - end - end - end - end -end |