aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/lib/active_job/queue_name.rb
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2014-08-17 16:54:26 -0700
committerDavid Heinemeier Hansson <david@loudthinking.com>2014-08-17 16:54:26 -0700
commit5d2de5c3b8d71ae7ffd1b4193edc1b169e00cd0e (patch)
tree959cf1f0132d89921fa1a276a2a8dc689e3c3aa0 /activejob/lib/active_job/queue_name.rb
parentc20c86ee9e944e38ce0eb581e4af3ad4af839875 (diff)
parent49c9f850fa3e2484e3aaf20b2479f61b1cc9375e (diff)
downloadrails-5d2de5c3b8d71ae7ffd1b4193edc1b169e00cd0e.tar.gz
rails-5d2de5c3b8d71ae7ffd1b4193edc1b169e00cd0e.tar.bz2
rails-5d2de5c3b8d71ae7ffd1b4193edc1b169e00cd0e.zip
Merge branch 'master' of github.com:rails/rails
Diffstat (limited to 'activejob/lib/active_job/queue_name.rb')
-rw-r--r--activejob/lib/active_job/queue_name.rb18
1 files changed, 18 insertions, 0 deletions
diff --git a/activejob/lib/active_job/queue_name.rb b/activejob/lib/active_job/queue_name.rb
new file mode 100644
index 0000000000..c2186d9fe9
--- /dev/null
+++ b/activejob/lib/active_job/queue_name.rb
@@ -0,0 +1,18 @@
+module ActiveJob
+ module QueueName
+ extend ActiveSupport::Concern
+
+ module ClassMethods
+ mattr_accessor(:default_queue_name) { "default" }
+
+ def queue_as(part_name)
+ self.queue_name = part_name.to_s.presence || default_queue_name
+ end
+ end
+
+ included do
+ class_attribute :queue_name
+ self.queue_name = default_queue_name
+ end
+ end
+end