diff options
Diffstat (limited to 'lib/active_job/queue_adapters/qu_adapter.rb')
-rw-r--r-- | lib/active_job/queue_adapters/qu_adapter.rb | 8 |
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 |