Merge pull request #261 from alphagov/sengi/threadpool

Allow tuning AMQP "consumer prefetch" (max unacked).
alphagov · Apr 24, 2024 · f68d8de · f68d8de
2 parents 6ce03b3 + b0fd78b
commit f68d8de
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/tasks/document_sync_worker.rake b/lib/tasks/document_sync_worker.rake
@@ -20,6 +20,7 @@ namespace :document_sync_worker do
       queue_name: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_NAME"),
       processor: PublishingApiMessageProcessor.new,
       worker_threads: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_THREADS", 1).to_i,
+      prefetch: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_MAX_UNACKED", 1).to_i,
     ).run
   rescue Interrupt
     Rails.logger.info("Stopping document sync worker (received interrupt)")