Merge pull request #259 from alphagov/sengi/threadpool

Enable concurrency in Bunny worker pool.
alphagov · Apr 24, 2024 · e24f5d0 · e24f5d0
2 parents 929390c + 6d5bcfc
commit e24f5d0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/Gemfile.lock b/Gemfile.lock
@@ -125,7 +125,7 @@ GEM
       sentry-rails (~> 5.3)
       sentry-ruby (~> 5.3)
       statsd-ruby (~> 1.5)
-    govuk_message_queue_consumer (4.2.0)
+    govuk_message_queue_consumer (5.0.0)
       bunny (~> 2.17)
     govuk_test (4.0.2)
       brakeman (>= 5.0.2)

diff --git a/lib/tasks/document_sync_worker.rake b/lib/tasks/document_sync_worker.rake
@@ -19,6 +19,7 @@ namespace :document_sync_worker do
     GovukMessageQueueConsumer::Consumer.new(
       queue_name: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_NAME"),
       processor: PublishingApiMessageProcessor.new,
+      worker_threads: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_THREADS", 1),
     ).run
   rescue Interrupt
     Rails.logger.info("Stopping document sync worker (received interrupt)")