Allow lambdas to be scheduled

Author: ethanhann

src/InEngine.Core.Test/InEngine.Core.Test.csproj

@@ -28,5 +28,8 @@
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
   </ItemGroup>
+  <ItemGroup>
+    <Folder Include="Scheduling\" />
+  </ItemGroup>
 </Project>
 

src/InEngine.Core.Test/Scheduling/ScheduleTest.cs

@@ -0,0 +1,37 @@
+using System;
+using BeekmanLabs.UnitTesting;
+using InEngine.Commands;
+using InEngine.Core.Commands;
+using InEngine.Core.Scheduling;
+using Moq;
+using NUnit.Framework;
+using Quartz;
+
+namespace InEngine.Core.Test.Scheduling
+{
+    [TestFixture]
+    public class ScheduleTest : TestBase<Schedule>
+    {
+        [SetUp]
+        public void Setup()
+        {
+            InEngineSettings.BasePath = TestContext.CurrentContext.TestDirectory;
+        }
+
+        [Test]
+        public void ShouldScheduleToRunCommandEverySecond()
+        {
+            var alwaysSucceed = new AlwaysSucceed();
+
+            Subject.Job(alwaysSucceed).EverySecond();
+        }
+
+        [Test]
+        public void ShouldScheduleToRunLambdaEverySecond()
+        {
+            var alwaysSucceed = new AlwaysSucceed();
+
+            Subject.Job(() => { Console.WriteLine("Hello, world!"); }).EverySecond();
+        }
+    }
+}

src/InEngine.Core.Test/appsettings.json

@@ -8,11 +8,7 @@
       "PrimaryQueueConsumers": 16,
       "SecondaryQueueConsumers": 4,
       "QueueDriver": "file",
-      "QueueName": "InEngineQueue",
-      "RedisHost": "localhost",
-      "RedisPort": 6379,
-      "RedisDb": 0,
-      "RedisPassword": ""
+      "QueueName": "InEngineQueue"
     }
   }
 }

src/InEngine.Core/Scheduling/Schedule.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using InEngine.Core.Commands;
 using InEngine.Core.Exceptions;
 using Quartz;
 using Quartz.Impl;
@@ -31,6 +32,11 @@ public Occurence Job(AbstractCommand command)
             };
         }
 
+        public Occurence Job(Action action)
+        {
+            return Job(new Lambda() { Action = action });
+        }
+
         public JobRegistration RegisterJob(AbstractCommand command, IJobDetail jobDetail, ITrigger trigger)
         {
             if (!JobGroups.ContainsKey(command.SchedulerGroup))