aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2014-05-19 11:04:23 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2014-05-19 11:04:23 +0200
commit60d76c5651ce9cf62caa1e7e80f56b84ec2b6abe (patch)
tree2043d595eaf258e007c5d7356fb086ea0e263b47 /lib
parent935f53bd5ad2d71cfa18a91514184eea3fb83690 (diff)
downloadrails-60d76c5651ce9cf62caa1e7e80f56b84ec2b6abe.tar.gz
rails-60d76c5651ce9cf62caa1e7e80f56b84ec2b6abe.tar.bz2
rails-60d76c5651ce9cf62caa1e7e80f56b84ec2b6abe.zip
Extract QueueName into its own module
Diffstat (limited to 'lib')
-rw-r--r--lib/active_job/base.rb17
-rw-r--r--lib/active_job/queue_name.rb10
2 files changed, 14 insertions, 13 deletions
diff --git a/lib/active_job/base.rb b/lib/active_job/base.rb
index d3b0fcffa8..fe3d1677dd 100644
--- a/lib/active_job/base.rb
+++ b/lib/active_job/base.rb
@@ -1,22 +1,13 @@
require 'active_job/queue_adapter'
-require 'active_job/queue_adapters/inline_adapter'
-require 'active_support/core_ext/string/inflections'
+require 'active_job/queue_name'
module ActiveJob
class Base
extend QueueAdapter
+ extend QueueName
- cattr_accessor(:queue_base_name) { "active_jobs" }
- cattr_accessor(:queue_name) { queue_base_name }
-
- class << self
- def enqueue(*args)
- queue_adapter.queue self, *args
- end
-
- def queue_as(part_name)
- self.queue_name = "#{queue_base_name}_#{part_name}"
- end
+ def self.enqueue(*args)
+ queue_adapter.queue self, *args
end
end
end \ No newline at end of file
diff --git a/lib/active_job/queue_name.rb b/lib/active_job/queue_name.rb
new file mode 100644
index 0000000000..a606b67370
--- /dev/null
+++ b/lib/active_job/queue_name.rb
@@ -0,0 +1,10 @@
+module ActiveJob
+ module QueueName
+ mattr_accessor(:queue_base_name) { "active_jobs" }
+ mattr_accessor(:queue_name) { queue_base_name }
+
+ def queue_as(part_name)
+ self.queue_name = "#{queue_base_name}_#{part_name}"
+ end
+ end
+end \ No newline at end of file