Add a thread listener list

Author: ethanhann

IntegrationEngine.Tests/IntegrationEngine.Tests.csproj

@@ -114,6 +114,7 @@
     <Compile Include="Api\TriggerControllerBaseTest.cs" />
     <Compile Include="Api\TriggerStub.cs" />
     <Compile Include="EngineHostCompositionRootTest.cs" />
+    <Compile Include="JobProcessor\ThreadedListenerManagerTest.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="..\configuration\IntegrationEngine.json">
@@ -163,4 +164,7 @@
   </Target>
   -->
   <ItemGroup />
+  <ItemGroup>
+    <Folder Include="JobProcessor\" />
+  </ItemGroup>
 </Project>

IntegrationEngine.Tests/JobProcessor/ThreadedListenerManagerTest.cs

@@ -0,0 +1,33 @@
+using BeekmanLabs.UnitTesting;
+using Common.Logging;
+using IntegrationEngine.JobProcessor;
+using Moq;
+using NUnit.Framework;
+using System;
+using System.Threading;
+
+namespace IntegrationEngine.Tests.JobProcessor
+{
+    public class ThreadedListenerManagerTest : TestBase<ThreadedListenerManager>
+    {
+        [Test]
+        public void ShouldSpawnAThread()
+        {
+            var cancellationTokenSource = new CancellationTokenSource();
+            Subject.CancellationTokenSource = cancellationTokenSource;
+            var mockMessageQueueListener = new Mock<IMessageQueueListener>();
+            Subject.MessageQueueListener = mockMessageQueueListener.Object;
+            mockMessageQueueListener.Setup(x => x.Listen(cancellationTokenSource.Token));
+            var mockLog = new Mock<ILog>();
+            Subject.Log = mockLog.Object;
+            var listenerStartMessage = "Message queue listener started.";
+            mockLog.Setup(x => x.Info(listenerStartMessage));
+
+            Subject.StartListener();
+
+            mockMessageQueueListener.Verify(x => x.Listen(cancellationTokenSource.Token), Times.Once);
+            mockLog.Verify(x => x.Info(listenerStartMessage), Times.Once);
+        }
+    }
+}
+

IntegrationEngine/IntegrationEngine.csproj

@@ -171,11 +171,11 @@
     <Compile Include="Api\Controllers\LogEventController.cs" />
     <Compile Include="EngineHostCompositionRoot.cs" />
     <Compile Include="JobProcessor\IThreadedListenerManager.cs" />
-    <Compile Include="JobProcessor\ThreadedListenerManager.cs" />
     <Compile Include="JobProcessor\IMessageQueueListener.cs" />
     <Compile Include="JobProcessor\MsmqListener.cs" />
     <Compile Include="JobProcessor\RabbitMQListener.cs" />
     <Compile Include="EngineConfiguration.cs" />
+    <Compile Include="JobProcessor\ThreadedListenerManager.cs" />
   </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <ItemGroup>

IntegrationEngine/JobProcessor/ThreadedListenerManager.cs

@@ -37,18 +37,18 @@ public void Dispose()
             listenerThread.Join();
         }
 
-        void listen()
+        void Listen()
         {
             MessageQueueListener.Listen(CancellationTokenSource.Token);
         }
 
         public void StartListener() 
         {
             if (listenerThread == null)
-                listenerThread = new Thread(listen);
+                listenerThread = new Thread(Listen);
             if (listenerThread.ThreadState == ThreadState.Running)
             {
-                Log.Info("Message queue listener already running.");
+                Log.Warn("Message queue listener already running.");
                 return;
             }