Autowire job context values to command properties

Author: ethanhann

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

@@ -49,7 +49,6 @@ public void ShouldConsumeSecondaryQueueBasedOnJobContextData()
             var jobExecutionConext = new Mock<IJobExecutionContext>();
             var jobDataMap = new JobDataMap { { "useSecondaryQueue", true } };
             jobExecutionConext.SetupGet(p => p.JobDetail.JobDataMap).Returns(jobDataMap);
-            Subject.JobExecutionContext = jobExecutionConext.Object;
 
             Subject.Run();
         }

src/InEngine.Core/AbstractCommand.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Linq;
 using InEngine.Core.IO;
 using Konsole;
 using Quartz;
@@ -7,7 +8,6 @@ namespace InEngine.Core
 {
     abstract public class AbstractCommand : ICommand, IFailed, IJob, IWrite
     {
-        public IJobExecutionContext JobExecutionContext { get; set; }
         public ProgressBar ProgressBar { get; internal set; }
         public string Name { get; set; }
         public string SchedulerGroup { get; set; }
@@ -45,7 +45,13 @@ public void UpdateProgress(int tick)
         #region Scheduling
         public void Execute(IJobExecutionContext context)
         {
-            JobExecutionContext = context;
+            var properties = GetType().GetProperties();
+            context.MergedJobDataMap.ToList().ForEach(x => {
+                var property = properties.FirstOrDefault(y => y.Name == x.Key);
+                if (property != null)
+                    property.SetValue(this, x.Value);                
+            });
+
             try
             {
                 Run();
@@ -56,19 +62,6 @@ public void Execute(IJobExecutionContext context)
             }
         }
 
-        public T GetJobContextData<T>(string key)
-        {
-            if (JobExecutionContext == null || JobExecutionContext.MergedJobDataMap == null)
-                return default(T);
-            var objectVal = JobExecutionContext.MergedJobDataMap.Get(key);
-            return objectVal == null ? default(T) : (T)objectVal;
-        }
-
-        public void AddJobContextData<T>(string key, T val)
-        {
-            JobExecutionContext.MergedJobDataMap.Add(key, val);
-        }
-
         #endregion
 
         #region Console output

src/InEngine.Core/Queue/Commands/Consume.cs

@@ -14,7 +14,6 @@ public class Consume : AbstractCommand
 
         public override void Run()
         {
-            UseSecondaryQueue = UseSecondaryQueue || GetJobContextData<bool>("useSecondaryQueue");
             var broker = Broker.Make(UseSecondaryQueue);
             var shouldConsume = true;
             while (shouldConsume)