aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/queue_adapters/que_adapter.rb
diff options
context:
space:
mode:
authorDouwe Maan <douwe@selenight.nl>2014-07-29 11:00:26 +0200
committerDouwe Maan <douwe@selenight.nl>2014-07-29 11:00:26 +0200
commitd1f9b0857f6afaab1b61b8c687942dd0b0f680ee (patch)
treed8ff870f6c720bd6cd627741361dc9a9db68a2da /lib/active_job/queue_adapters/que_adapter.rb
parent63f92c0205ee3abcbc299c000f62d3caffc61323 (diff)
downloadrails-d1f9b0857f6afaab1b61b8c687942dd0b0f680ee.tar.gz
rails-d1f9b0857f6afaab1b61b8c687942dd0b0f680ee.tar.bz2
rails-d1f9b0857f6afaab1b61b8c687942dd0b0f680ee.zip
Rename variables for consistency.
Diffstat (limited to 'lib/active_job/queue_adapters/que_adapter.rb')
-rw-r--r--lib/active_job/queue_adapters/que_adapter.rb6
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/active_job/queue_adapters/que_adapter.rb b/lib/active_job/queue_adapters/que_adapter.rb
index 4af3a0fbcf..15a607bcb6 100644
--- a/lib/active_job/queue_adapters/que_adapter.rb
+++ b/lib/active_job/queue_adapters/que_adapter.rb
@@ -5,7 +5,7 @@ module ActiveJob
class QueAdapter
class << self
def enqueue(job, *args)
- JobWrapper.enqueue job.to_s, *args, queue: job.queue_name
+ JobWrapper.enqueue job.name, *args, queue: job.queue_name
end
def enqueue_at(job, timestamp, *args)
@@ -14,8 +14,8 @@ module ActiveJob
end
class JobWrapper < Que::Job
- def run(job, *args)
- job.constantize.new.execute *args
+ def run(job_name, *args)
+ job_name.constantize.new.execute *args
end
end
end