diff options
author | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2015-05-03 17:39:50 -0300 |
---|---|---|
committer | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2015-05-03 17:39:50 -0300 |
commit | b4b29536e59f3e9e71155ed60148fe1f1e345283 (patch) | |
tree | 2706579c4c7ddd9d0c44245927dfa49842d50a2b /activejob/lib/active_job/queue_adapters | |
parent | 982db48bcbf28057dc178f86b1d2c77f2dc28c15 (diff) | |
parent | fdfca02c304d809aac53ebf8094b237d0ba6415e (diff) | |
download | rails-b4b29536e59f3e9e71155ed60148fe1f1e345283.tar.gz rails-b4b29536e59f3e9e71155ed60148fe1f1e345283.tar.bz2 rails-b4b29536e59f3e9e71155ed60148fe1f1e345283.zip |
Merge pull request #19498 from chanks/activejob-que-remove-named-queues
ActiveJob: Stop using Que's named queues.
Diffstat (limited to 'activejob/lib/active_job/queue_adapters')
-rw-r--r-- | activejob/lib/active_job/queue_adapters/que_adapter.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/activejob/lib/active_job/queue_adapters/que_adapter.rb b/activejob/lib/active_job/queue_adapters/que_adapter.rb index 84cc2845b0..a1a41ccc32 100644 --- a/activejob/lib/active_job/queue_adapters/que_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/que_adapter.rb @@ -16,11 +16,11 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :que class QueAdapter def enqueue(job) #:nodoc: - JobWrapper.enqueue job.serialize, queue: job.queue_name + JobWrapper.enqueue job.serialize end def enqueue_at(job, timestamp) #:nodoc: - JobWrapper.enqueue job.serialize, queue: job.queue_name, run_at: Time.at(timestamp) + JobWrapper.enqueue job.serialize, run_at: Time.at(timestamp) end class JobWrapper < Que::Job #:nodoc: |