Merge pull request #2889 from alphagov/sengi/rm-mq-statsd

Stop passing statsd (deprecated) to MQ client.

lib/tasks/message_queue.rake

@@ -17,7 +17,6 @@ namespace :message_queue do
     GovukMessageQueueConsumer::Consumer.new(
       queue_name: "search_api_to_be_indexed",
       processor: Indexer::MessageProcessor.new,
-      statsd_client: Services.statsd_client,
     ).run
   end
 
@@ -26,7 +25,6 @@ namespace :message_queue do
     GovukMessageQueueConsumer::Consumer.new(
       queue_name: "search_api_govuk_index",
       processor: GovukIndex::PublishingEventProcessor.new,
-      statsd_client: Services.statsd_client,
     ).run
   end
 
@@ -35,7 +33,6 @@ namespace :message_queue do
     GovukMessageQueueConsumer::Consumer.new(
       queue_name: "search_api_bulk_reindex",
       processor: GovukIndex::PublishingEventProcessor.new,
-      statsd_client: Services.statsd_client,
     ).run
   end
 end

spec/unit/tasks/message_queue_spec.rb

@@ -5,9 +5,6 @@
 RSpec.describe Indexer::MessageProcessor, "RakeTest" do
   context "when indexing published documents to publishing-api" do
     it "use GovukMessageQueueConsumer::Consumer" do
-      statsd_client = Statsd.new
-      expect(Services).to receive(:statsd_client).and_return(statsd_client)
-
       indexer = described_class.new
       expect(described_class).to receive(:new).and_return(indexer)
 
@@ -18,7 +15,6 @@
         .with(
           queue_name: "search_api_to_be_indexed",
           processor: indexer,
-          statsd_client:,
         ).and_return(consumer)
 
       Rake::Task["message_queue:listen_to_publishing_queue"].invoke