From 42f5ba37a4bf3cd9369643e479b91a5f97bce779 Mon Sep 17 00:00:00 2001
From: Mike Perham <mperham@gmail.com>
Date: Tue, 20 May 2014 06:57:29 -0700
Subject: Remove all Sidekiq-specific stuff from job, enable retries by default

---
 lib/active_job/queue_adapters/sidekiq_adapter.rb | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

(limited to 'lib/active_job/queue_adapters/sidekiq_adapter.rb')

diff --git a/lib/active_job/queue_adapters/sidekiq_adapter.rb b/lib/active_job/queue_adapters/sidekiq_adapter.rb
index 087e833d24..0cf9e47287 100644
--- a/lib/active_job/queue_adapters/sidekiq_adapter.rb
+++ b/lib/active_job/queue_adapters/sidekiq_adapter.rb
@@ -5,8 +5,11 @@ module ActiveJob
     class SidekiqAdapter
       class << self
         def queue(job, *args)
-          item = { 'class' => JobWrapper, 'queue' => job.queue_name, 'args' => [job, *args] }
-          Sidekiq::Client.push(job.get_sidekiq_options.merge(item))
+          item = { 'class' => JobWrapper,
+                   'queue' => job.queue_name,
+                   'args' => [job, *args],
+                   'retry' => true }
+          Sidekiq::Client.push(item)
         end
       end
 
@@ -15,14 +18,9 @@ module ActiveJob
 
         def perform(job_name, *args)
           instance = job_name.constantize.new
-          instance.jid = self.jid
           instance.perform *Parameters.deserialize(args)
         end
       end
     end
   end
 end
-
-class ActiveJob::Base
-  include Sidekiq::Worker
-end
-- 
cgit v1.2.3