Merge pull request #103 from cristianbica/adapter-fixes

Fixed qu, queue_classic, sneakers adapters

lib/active_job/queue_adapters/qu_adapter.rb

@@ -5,7 +5,9 @@ module QueueAdapters
     class QuAdapter
       class << self
         def enqueue(job, *args)
-          Qu::Payload.new(klass: JobWrapper, args: [job, *args], queue: job.queue_name).push
+          Qu::Payload.new(klass: JobWrapper, args: [job.name, *args]).tap do |payload|
+            payload.instance_variable_set(:@queue, job.queue_name)
+          end.push
         end
 
         def enqueue_at(job, timestamp, *args)
@@ -14,8 +16,8 @@ def enqueue_at(job, timestamp, *args)
       end
 
       class JobWrapper < Qu::Job
-        def initialize(job, *args)
-          @job  = job
+        def initialize(job_name, *args)
+          @job  = job_name.constantize
           @args = args
         end
 

lib/active_job/queue_adapters/queue_classic_adapter.rb

@@ -5,7 +5,7 @@ module QueueAdapters
     class QueueClassicAdapter
       class << self
         def enqueue(job, *args)
-          QC::Queue.new(job.queue_name).enqueue("#{JobWrapper.name}.perform", job, *args)
+          QC::Queue.new(job.queue_name).enqueue("#{JobWrapper.name}.perform", job.name, *args)
         end
 
         def enqueue_at(job, timestamp, *args)
@@ -14,8 +14,8 @@ def enqueue_at(job, timestamp, *args)
       end
 
       class JobWrapper
-        def self.perform(job, *args)
-          job.new.execute *args
+        def self.perform(job_name, *args)
+          job_name.constantize.new.execute *args
         end
       end
     end

lib/active_job/queue_adapters/sneakers_adapter.rb

@@ -10,7 +10,7 @@ class << self
         def enqueue(job, *args)
           @monitor.synchronize do
             JobWrapper.from_queue job.queue_name
-            JobWrapper.enqueue [ job, *args ]
+            JobWrapper.enqueue ActiveSupport::JSON.encode([ job.name, *args ])
           end
         end
 
@@ -22,8 +22,10 @@ def enqueue_at(job, timestamp, *args)
       class JobWrapper
         include Sneakers::Worker
 
-        def work(job, *args)
-          job.new.execute *args
+        def work(msg)
+          job_name, *args = ActiveSupport::JSON.decode(msg)
+          job_name.constantize.new.execute *args
+          ack!
         end
       end
     end