aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDouwe Maan <douwe@selenight.nl>2014-05-19 14:00:14 +0200
committerDouwe Maan <douwe@selenight.nl>2014-05-19 14:00:14 +0200
commit68793bff197d47be9f5742c78eff0b547281c83e (patch)
tree046b9c46cfb91fcb19adff9a3d5a4d41869feeb6
parentc086dfbb99cbd49dadd51cc6b301125806684d42 (diff)
downloadrails-68793bff197d47be9f5742c78eff0b547281c83e.tar.gz
rails-68793bff197d47be9f5742c78eff0b547281c83e.tar.bz2
rails-68793bff197d47be9f5742c78eff0b547281c83e.zip
Refactor Resque adapter to be more consistent with others
-rw-r--r--lib/active_job/queue_adapters/resque_adapter.rb10
1 files changed, 3 insertions, 7 deletions
diff --git a/lib/active_job/queue_adapters/resque_adapter.rb b/lib/active_job/queue_adapters/resque_adapter.rb
index bb5f3df8d6..6686f10593 100644
--- a/lib/active_job/queue_adapters/resque_adapter.rb
+++ b/lib/active_job/queue_adapters/resque_adapter.rb
@@ -7,16 +7,12 @@ module ActiveJob
class ResqueAdapter
class << self
def queue(job, *args)
- Resque.enqueue *JobWrapper.wrap(job, args)
+ Resque.enqueue JobWrapper.new(job), job, *args
end
end
class JobWrapper
class << self
- def wrap(job, args)
- [ new(job), *args.prepend(job) ]
- end
-
def perform(job_name, *args)
job_name.constantize.new.perform *Parameters.deserialize(args)
end
@@ -27,9 +23,9 @@ module ActiveJob
end
def to_s
- self.class.to_s
+ self.class.name
end
end
end
end
-end \ No newline at end of file
+end