diff --git a/app/jobs/main_job.rb b/app/jobs/main_job.rb index b9a0e0f..d0d117c 100644 --- a/app/jobs/main_job.rb +++ b/app/jobs/main_job.rb @@ -1,11 +1,13 @@ -class MainJob < ApplicationJob - queue_as :default +class MainJob + include Sidekiq::Worker + + sidekiq_options queue: 'default' AMOUNT_SUB_JOBS = 250_000 def perform AMOUNT_SUB_JOBS.times do |index| - SubJob.perform_later(index) + SubJob.perform_async(index) end end end diff --git a/app/jobs/sub_job.rb b/app/jobs/sub_job.rb index 2248a62..10ea65e 100644 --- a/app/jobs/sub_job.rb +++ b/app/jobs/sub_job.rb @@ -1,5 +1,7 @@ -class SubJob < ApplicationJob - queue_as :default +class SubJob + include Sidekiq::Worker + + sidekiq_options queue: 'default' def perform(index) puts "Performing Job with index ##{index}" diff --git a/lib/tasks/sidekiq/test.rake b/lib/tasks/sidekiq/test.rake index a7b75d5..e4aa97d 100644 --- a/lib/tasks/sidekiq/test.rake +++ b/lib/tasks/sidekiq/test.rake @@ -1,6 +1,6 @@ namespace :sidekiq do desc 'Sidekiq performance test with ActiveJob' task :test => :environment do - MainJob.perform_later + MainJob.perform_async end end