Add timeout to queued command

Author: ethanhann

src/InEngine.Core/Queuing/Clients/FileClient.cs

@@ -3,6 +3,7 @@
 using System.IO;
 using System.Linq;
 using InEngine.Core.Exceptions;
+using Quartz;
 
 namespace InEngine.Core.Queuing.Clients
 {
@@ -81,7 +82,7 @@ public bool Consume()
             var message = File.ReadAllText(inProgressFilePath).DeserializeFromJson<Message>();
             try
             {
-                Queue.ExtractCommandInstanceFromMessage(message as IMessage).Run();
+                Queue.ExtractCommandInstanceFromMessageAndRun(message as IMessage);
             }
             catch (Exception exception)
             {

src/InEngine.Core/Queuing/Clients/RedisClient.cs

@@ -50,11 +50,10 @@ public bool Consume()
             var message = serializedMessage.DeserializeFromJson<Message>();
             if (message == null)
                 return false;
-            var commandInstance = Queue.ExtractCommandInstanceFromMessage(message);
 
             try
             {
-                commandInstance.Run();
+                Queue.ExtractCommandInstanceFromMessageAndRun(message as IMessage);
             }
             catch (Exception exception)
             {

src/InEngine.Core/Queuing/Queue.cs

@@ -5,6 +5,7 @@
 using InEngine.Core.Exceptions;
 using InEngine.Core.Queuing.Clients;
 using Newtonsoft.Json;
+using Quartz;
 using Serialize.Linq.Extensions;
 
 namespace InEngine.Core.Queuing
@@ -80,6 +81,15 @@ public static ICommand ExtractCommandInstanceFromMessage(IMessage message)
             ) as ICommand;
         }
 
+        public static void ExtractCommandInstanceFromMessageAndRun(IMessage message)
+        {
+            var command = ExtractCommandInstanceFromMessage(message);
+            if (command is IJob)
+                (command as IJob).Execute(null);
+            else
+                command.Run();
+        }
+
         public long GetPendingQueueLength()
         {
             return QueueClient.GetPendingQueueLength();