Add support for que name to Que adapter.

activejob/CHANGELOG.md

@@ -1,3 +1,7 @@
+*   Add queue name support to Que adapter
+
+    *Brad Nauta*, *Wojciech Wnętrzak*
+
 *   Don't run `after_enqueue` and `after_perform` callbacks if the callback chain is halted.
 
         class MyJob < ApplicationJob

activejob/lib/active_job/queue_adapters/que_adapter.rb

@@ -18,13 +18,13 @@ module QueueAdapters
     #   Rails.application.config.active_job.queue_adapter = :que
     class QueAdapter
       def enqueue(job) #:nodoc:
-        que_job = JobWrapper.enqueue job.serialize, priority: job.priority
+        que_job = JobWrapper.enqueue job.serialize, priority: job.priority, queue: job.queue_name
         job.provider_job_id = que_job.attrs["job_id"]
         que_job
       end
 
       def enqueue_at(job, timestamp) #:nodoc:
-        que_job = JobWrapper.enqueue job.serialize, priority: job.priority, run_at: Time.at(timestamp)
+        que_job = JobWrapper.enqueue job.serialize, priority: job.priority, queue: job.queue_name, run_at: Time.at(timestamp)
         job.provider_job_id = que_job.attrs["job_id"]
         que_job
       end

activejob/test/integration/queuing_test.rb

@@ -15,7 +15,7 @@ class QueuingTest < ActiveSupport::TestCase
   end
 
   test "should not run jobs queued on a non-listening queue" do
-    skip if adapter_is?(:inline, :async, :sucker_punch, :que)
+    skip if adapter_is?(:inline, :async, :sucker_punch)
     old_queue = TestJob.queue_name
 
     begin

activejob/test/support/integration/adapters/que.rb

@@ -25,7 +25,7 @@ def start_workers
 
     @thread = Thread.new do
       loop do
-        Que::Job.work
+        Que::Job.work("integration_tests")
         sleep 0.5
       end
     end

activejob/test/support/que/inline.rb

@@ -9,6 +9,7 @@ def self.enqueue(*args)
       options = args.pop
       options.delete(:run_at)
       options.delete(:priority)
+      options.delete(:queue)
       args << options unless options.empty?
     end
     run(*args)