diff options
author | Douwe Maan <douwe@selenight.nl> | 2014-05-19 14:00:14 +0200 |
---|---|---|
committer | Douwe Maan <douwe@selenight.nl> | 2014-05-19 14:00:14 +0200 |
commit | 68793bff197d47be9f5742c78eff0b547281c83e (patch) | |
tree | 046b9c46cfb91fcb19adff9a3d5a4d41869feeb6 | |
parent | c086dfbb99cbd49dadd51cc6b301125806684d42 (diff) | |
download | rails-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.rb | 10 |
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 |