From b32fdd5731aa0a6b8ed77305f78aba17a730b8e8 Mon Sep 17 00:00:00 2001 From: David Heinemeier Hansson Date: Sun, 18 May 2014 16:24:30 +0200 Subject: Queue naming with a base, which requires a JobWrapper to comply to Resques expectation of a class variable --- lib/active_job/base.rb | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'lib/active_job/base.rb') diff --git a/lib/active_job/base.rb b/lib/active_job/base.rb index e18c9d4309..341ea6158b 100644 --- a/lib/active_job/base.rb +++ b/lib/active_job/base.rb @@ -3,12 +3,18 @@ require 'active_job/queue_adapters/resque_adapter' module ActiveJob class Base - cattr_accessor(:queue_adapter) { ActiveJob::QueueAdapters::InlineAdapter } - + cattr_accessor(:queue_adapter) { ActiveJob::QueueAdapters::InlineAdapter } + 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 end end end \ No newline at end of file -- cgit v1.2.3