1 files changed, 6 insertions, 6 deletions
diff --git a/activejob/lib/active_job/queue_adapters/que_adapter.rb b/activejob/lib/active_job/queue_adapters/que_adapter.rb
index 9c84c74f83..51891ab07b 100644
--- a/activejob/lib/active_job/queue_adapters/que_adapter.rb
+++ b/activejob/lib/active_job/queue_adapters/que_adapter.rb
@@ -4,18 +4,18 @@ module ActiveJob
   module QueueAdapters
     class QueAdapter
       class << self
-        def enqueue(job, *args)
-          JobWrapper.enqueue job.name, *args, queue: job.queue_name
+        def enqueue(job)
+          JobWrapper.enqueue job.serialize, queue: job.queue_name
         end
 
-        def enqueue_at(job, timestamp, *args)
-          JobWrapper.enqueue job.name, *args, queue: job.queue_name, run_at: Time.at(timestamp)
+        def enqueue_at(job, timestamp)
+          JobWrapper.enqueue job.serialize, queue: job.queue_name, run_at: Time.at(timestamp)
         end
       end
 
       class JobWrapper < Que::Job
-        def run(job_name, *args)
-          job_name.constantize.new.execute(*args)
+        def run(job_data)
+          Base.execute job_data
         end
       end
     end