Merge pull request #1431 from sanger/1427-y24-306---bug-as-developers…

…-we-need-to-modify-the-emq-publishing-job-so-it-doesnt-raise-an-error-as-this-stops-users-being-able-to-create-libraries-pools-or-runs-if-the-queue-is-down

Updating the code to not to throw when the EMQ is down

app/messages/emq/publishing_job.rb

@@ -73,8 +73,10 @@ def publish(objects, message_config, schema_key) # rubocop:disable Metrics/AbcSi
         # Log success message after successful publishing
         Rails.logger.info('Published volume tracking message to EMQ')
       rescue StandardError => e
-        # Raise an exception if any error occurs
-        raise "Failed to publish message to EMQ: #{e.message}"
+        # DO NOT Raise an exception if any error occurs; logs the error instead
+        # This is to prevent the job from failing and to allow the job to continue
+        # These logs can be monitored through Kibana
+        Rails.logger.error("Failed to publish message to EMQ: #{e.message}")
       end
     end
 

spec/messages/emq/publishing_job_spec.rb

@@ -104,4 +104,10 @@
     assert_equal 'create-aliquot-in-mlwh', deep_struct.amqp.schemas.subjects.volume_tracking.subject
     assert_equal 1, deep_struct.amqp.schemas.subjects.volume_tracking.version
   end
+
+  it 'logs error message when the EMQ is down' do
+    allow(emq_sender_mock).to receive(:send_message).and_raise(StandardError)
+    expect(Rails.logger).to receive(:error).with('Failed to publish message to EMQ: StandardError')
+    publishing_job.publish(aliquot, Pipelines.pacbio, 'volume_tracking')
+  end
 end