Add a few more tests

Author: ethanhann

src/InEngine.Core.Tests/InEngine.Core.Tests.csproj

@@ -41,9 +41,17 @@
     <Reference Include="Quartz">
       <HintPath>..\packages\Quartz.2.6.1\lib\net40\Quartz.dll</HintPath>
     </Reference>
+    <Reference Include="Castle.Core">
+      <HintPath>..\packages\Castle.Core.4.2.1\lib\net45\Castle.Core.dll</HintPath>
+    </Reference>
+    <Reference Include="System.Configuration" />
+    <Reference Include="Moq">
+      <HintPath>..\packages\Moq.4.7.145\lib\net45\Moq.dll</HintPath>
+    </Reference>
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Queue\Commands\PublishTest.cs" />
+    <Compile Include="Queue\Commands\ConsumeTest.cs" />
   </ItemGroup>
   <ItemGroup>
     <None Include="packages.config" />

src/InEngine.Core.Tests/Queue/Commands/ConsumeTest.cs

@@ -0,0 +1,68 @@
+using System.Collections.Generic;
+using System.Linq;
+using BeekmanLabs.UnitTesting;
+using InEngine.Core.Exceptions;
+using InEngine.Core.Queue.Commands;
+using Moq;
+using NUnit.Framework;
+using Quartz;
+
+namespace InEngine.Core.Tests.Queue.Commands
+{
+    [TestFixture]
+    public class ConsumeTest : TestBase<Consume>
+    {
+        [SetUp]
+        public void Setup()
+        {
+            InEngineSettings.BasePath = TestContext.CurrentContext.TestDirectory;
+        }
+
+        [Test]
+        public void ShouldConsumePrimaryQueue()
+        {
+            var expectedMessage = "Consumed";
+            new Publish() {
+                Command = new Null()
+            }.Run();
+
+            var result = Subject.Run();
+
+            Assert.IsTrue(result.IsSuccessful);
+            Assert.AreEqual(expectedMessage, result.Message);
+        }
+
+        [Test]
+        public void ShouldConsumeSecondaryQueue()
+        {
+            var expectedMessage = "Consumed";
+            new Publish() {
+                Command = new Null()
+            }.Run();
+            Subject.UseSecondaryQueue = true;
+
+            var result = Subject.Run();
+
+            Assert.IsTrue(result.IsSuccessful);
+            Assert.AreEqual(expectedMessage, result.Message);
+        }
+
+        [Test]
+        public void ShouldConsumeSecondaryQueueBasedOnJobContextData()
+        {
+            var expectedMessage = "Consumed";
+            new Publish() {
+                Command = new Null()
+            }.Run();
+            var jobExecutionConext = new Mock<IJobExecutionContext>();
+            var jobDataMap = new JobDataMap { { "useSecondaryQueue", true } };
+            jobExecutionConext.SetupGet(p => p.JobDetail.JobDataMap).Returns(jobDataMap);
+            Subject.JobExecutionContext = jobExecutionConext.Object;
+
+            var result = Subject.Run();
+
+            Assert.IsTrue(result.IsSuccessful);
+            Assert.AreEqual(expectedMessage, result.Message);
+        }
+    }
+}

src/InEngine.Core.Tests/Queue/Commands/PublishTest.cs

@@ -1,5 +1,4 @@
-using System;
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Linq;
 using BeekmanLabs.UnitTesting;
 using InEngine.Core.Exceptions;

src/InEngine.Core.Tests/packages.config

@@ -1,8 +1,10 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
   <package id="BeekmanLabs.UnitTesting" version="0.0.0" targetFramework="net461" />
+  <package id="Castle.Core" version="4.2.1" targetFramework="net462" />
   <package id="Common.Logging" version="3.3.1" targetFramework="net462" />
   <package id="Common.Logging.Core" version="3.3.1" targetFramework="net462" />
+  <package id="Moq" version="4.7.145" targetFramework="net462" />
   <package id="NUnit" version="3.9.0" targetFramework="net462" />
   <package id="Quartz" version="2.6.1" targetFramework="net462" />
 </packages>