Split listener setup and start actions for testability

Author: ethanhann

IntegrationEngine.Tests/EngineHostCompositionRootTest.cs

@@ -61,6 +61,18 @@ public void ShouldSetupMessageQueueListener()
             Assert.That(Subject.MessageQueueListenerManager, Is.Not.Null);
         }
 
+        [Test]
+        public void ShouldStartMessageQueueListener()
+        {
+            var mockMessageQueueListenerManager = new Mock<IMessageQueueListenerManager>();
+            mockMessageQueueListenerManager.Setup(x => x.StartListener());
+            Subject.MessageQueueListenerManager = mockMessageQueueListenerManager.Object;
+
+            Subject.StartMessageQueueListener();
+
+            mockMessageQueueListenerManager.Verify(x => x.StartListener(), Times.Once);
+        }
+
         [Test]
         public void ShouldSetupRScriptRunner()
         {

IntegrationEngine/EngineHostCompositionRoot.cs

@@ -64,8 +64,10 @@ public void Configure()
             RegisterIntegrationJobs();
             SetupRScriptRunner();
             SetupElasticsearchRepository();
-            if (IsMessageQueueListenerManagerEnabled)
+            if (IsMessageQueueListenerManagerEnabled) {
                 SetupMessageQueueListenerManager();
+                StartMessageQueueListener();
+            }
             if (IsSchedulerEnabled)
                 SetupEngineScheduler();
             if (IsWebApiEnabled)
@@ -174,16 +176,20 @@ public void RegisterIntegrationJobs()
             });
         }
 
-        public async void SetupMessageQueueListenerManager()
+        public void SetupMessageQueueListenerManager()
         {
             var config = Container.Resolve<IRabbitMQConfiguration>("DefaultRabbitMQ");
             var messageQueueListenerFactory = new MessageQueueListenerFactory(Container, IntegrationJobTypes, config);
             MessageQueueListenerManager = new MessageQueueListenerManager() {
                 MessageQueueListenerFactory = messageQueueListenerFactory,
             };
+        }
+
+        public async void StartMessageQueueListener()
+        {
             await MessageQueueListenerManager.StartListener();
         }
-            
+
         public void SetupEngineScheduler()
         {
             var dispatcher = new Dispatcher() {