aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/lib/active_job/queue_name.rb
diff options
context:
space:
mode:
authorAbdelkader Boudih <terminale@gmail.com>2014-08-18 08:17:36 +0000
committerAbdelkader Boudih <terminale@gmail.com>2014-08-18 20:04:02 +0000
commit68c643f8e70084d89f7bddff2b863b6b83411f4a (patch)
tree52f0e2107546945452924edae69366f93cc2171e /activejob/lib/active_job/queue_name.rb
parent879dde9b1afbe69e31d355f3197183b99b7a7187 (diff)
downloadrails-68c643f8e70084d89f7bddff2b863b6b83411f4a.tar.gz
rails-68c643f8e70084d89f7bddff2b863b6b83411f4a.tar.bz2
rails-68c643f8e70084d89f7bddff2b863b6b83411f4a.zip
[ActiveJob] Add queue_name_prefix so all queue are prefixed .
We can split queues on a per environement basis as well as seggregate per application so we can split queues on a per env basis ActiveJob::Base.queue_name_prefix = 'foo'
Diffstat (limited to 'activejob/lib/active_job/queue_name.rb')
-rw-r--r--activejob/lib/active_job/queue_name.rb5
1 files changed, 4 insertions, 1 deletions
diff --git a/activejob/lib/active_job/queue_name.rb b/activejob/lib/active_job/queue_name.rb
index c2186d9fe9..9698835b6e 100644
--- a/activejob/lib/active_job/queue_name.rb
+++ b/activejob/lib/active_job/queue_name.rb
@@ -3,10 +3,13 @@ module ActiveJob
extend ActiveSupport::Concern
module ClassMethods
+ mattr_accessor(:queue_name_prefix)
mattr_accessor(:default_queue_name) { "default" }
def queue_as(part_name)
- self.queue_name = part_name.to_s.presence || default_queue_name
+ queue_name = part_name.to_s.presence || default_queue_name
+ name_parts = [queue_name_prefix.presence, queue_name]
+ self.queue_name = name_parts.compact.join('_')
end
end