Fixed qu, queue_classic, sneakers adapters

1 files changed, 5 insertions, 3 deletions

diff --git a/lib/active_job/queue_adapters/qu_adapter.rb b/lib/active_job/queue_adapters/qu_adapter.rb
index 7e69229801..cdf4ae4ce9 100644
--- a/lib/active_job/queue_adapters/qu_adapter.rb
+++ b/lib/active_job/queue_adapters/qu_adapter.rb
@@ -5,7 +5,9 @@ module ActiveJob
     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 @@ module ActiveJob
       end
 
       class JobWrapper < Qu::Job
-        def initialize(job, *args)
-          @job  = job
+        def initialize(job_name, *args)
+          @job  = job_name.constantize
           @args = args
         end