Merge pull request #85 from DouweM/queue_name

Have .queue_as only set queue name for job in question.

2 files changed, 13 insertions, 5 deletions

diff --git a/lib/active_job/base.rb b/lib/active_job/base.rb
index 0c772e3126..d5ba253016 100644
--- a/lib/active_job/base.rb
+++ b/lib/active_job/base.rb
@@ -9,8 +9,8 @@ require 'active_job/logging'
 module ActiveJob
   class Base
     extend QueueAdapter
-    extend QueueName
 
+    include QueueName
     include Enqueuing
     include Execution
     include Callbacks
diff --git a/lib/active_job/queue_name.rb b/lib/active_job/queue_name.rb
index a606b67370..859ddad034 100644
--- a/lib/active_job/queue_name.rb
+++ b/lib/active_job/queue_name.rb
@@ -1,10 +1,18 @@
 module ActiveJob
   module QueueName
-    mattr_accessor(:queue_base_name) { "active_jobs" }
-    mattr_accessor(:queue_name)      { queue_base_name }
+    extend ActiveSupport::Concern
 
-    def queue_as(part_name)
-      self.queue_name = "#{queue_base_name}_#{part_name}"
+    module ClassMethods
+      mattr_accessor(:queue_base_name) { "active_jobs" }
+
+      def queue_as(part_name)
+        self.queue_name = "#{queue_base_name}_#{part_name}"
+      end
+    end
+
+    included do
+      class_attribute :queue_name
+      self.queue_name = queue_base_name
     end
   end
 end
\ No newline at end of file