WIP

Author: ioquatix

examples/benchmark/async-job-client.rb

@@ -5,6 +5,7 @@
 # Copyright, 2024-2025, by Samuel Williams.
 # Copyright, 2025, by Shopify Inc.
 
+require "async"
 require_relative "config/environment"
 
 start_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)

examples/benchmark/async-job-server.rb

@@ -5,8 +5,8 @@
 # Copyright, 2024-2025, by Samuel Williams.
 # Copyright, 2025, by Shopify Inc.
 
-require "async/job/adapter/active_job/service"
+require "async/job/adapter/active_job/environment"
 
 service "job-server" do
-	include Async::Job::Adapter::ActiveJob::Service
+	include Async::Job::Adapter::ActiveJob::Environment
 end

examples/benchmark/config/environment.rb

@@ -7,11 +7,11 @@
 require "rails"
 require "active_job/railtie"
 require "async/job/adapter/active_job/railtie"
+require "async/job/processor/redis"
 
 Async::Job::Adapter::ActiveJob::Railtie.define_queue "default" do
-	dequeue Async::Job::Queue::Redis
+	# enqueue Async::Job::Processor::Aggregate
+	dequeue Async::Job::Processor::Redis
 end
 
-ActiveJob::Base.queue_adapter = Async::Job::Adapter::ActiveJob::Railtie.config.active_job.queue_adapter
-
 require_relative "../benchmark_job"