diff options
author | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2014-05-19 09:04:48 -0300 |
---|---|---|
committer | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2014-05-19 09:04:48 -0300 |
commit | 8a05587227f00317e016b1cf2c15ed84c7699a8b (patch) | |
tree | 046b9c46cfb91fcb19adff9a3d5a4d41869feeb6 /lib | |
parent | c086dfbb99cbd49dadd51cc6b301125806684d42 (diff) | |
parent | 68793bff197d47be9f5742c78eff0b547281c83e (diff) | |
download | rails-8a05587227f00317e016b1cf2c15ed84c7699a8b.tar.gz rails-8a05587227f00317e016b1cf2c15ed84c7699a8b.tar.bz2 rails-8a05587227f00317e016b1cf2c15ed84c7699a8b.zip |
Merge pull request #23 from DouweM/patch-2
Refactor Resque adapter to be more consistent with others
Diffstat (limited to 'lib')
-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 |