Allow queue to publish a lambda command

Author: ethanhann

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

@@ -3,6 +3,7 @@
 using System.Data;
 using System.Data.SqlClient;
 using System.Linq;
+using InEngine.Core.Commands;
 using InEngine.Core.Exceptions;
 using InEngine.Core.Queuing.Clients.Database;
 using Newtonsoft.Json;
@@ -32,6 +33,11 @@ public void Publish(ICommand command)
             }
         }
 
+        public void Publish(Action action)
+        {
+            Publish(new Lambda() { Action = action });
+        }
+
         public bool Consume()
         {
 

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

@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using InEngine.Core.Commands;
 using InEngine.Core.Exceptions;
 
 namespace InEngine.Core.Queuing.Clients
@@ -58,6 +59,11 @@ public void Publish(ICommand command)
             }   
         }
 
+        public void Publish(Action action)
+        {
+            Publish(new Lambda() { Action = action });
+        }
+
         public bool Consume()
         {
             var fileInfo = new DirectoryInfo(PendingQueuePath)

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

@@ -1,10 +1,8 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
-using System.Reflection;
-using System.Threading.Tasks;
+using InEngine.Core.Commands;
 using InEngine.Core.Exceptions;
-using Newtonsoft.Json;
 using StackExchange.Redis;
 
 namespace InEngine.Core.Queuing.Clients
@@ -27,16 +25,15 @@ public class RedisClient : IQueueClient
         });
         public static ConnectionMultiplexer Connection { get { return lazyConnection.Value; } } 
         public ConnectionMultiplexer _connectionMultiplexer;
-        public IDatabase Redis
-        {
-            get
-            {
-                return Connection.GetDatabase(RedisDb);
-            }
-        }
+        public IDatabase Redis { get { return Connection.GetDatabase(RedisDb); } }
         public bool UseCompression { get; set; }
         public int RedisDb { get; set; }
 
+        public void Publish(Action action)
+        {
+            Publish(new Lambda() { Action = action });
+        }
+
         public void Publish(ICommand command)
         {
             Redis.ListLeftPush(

src/InEngine.Core/Queuing/IQueueClient.cs

@@ -9,6 +9,7 @@ public interface IQueueClient
         string QueueName { get; set; }
         bool UseCompression { get; set; }
         void Publish(ICommand command);
+        void Publish(Action action);
         bool Consume();
         long GetPendingQueueLength();
         long GetInProgressQueueLength();

src/InEngine.Core/Queuing/Queue.cs

@@ -49,6 +49,11 @@ public static Queue Make(bool useSecondaryQueue = false)
             return queue;
         }
 
+        public void Publish(Action action)
+        {
+            QueueClient.Publish(action);
+        }
+
         public void Publish(ICommand command)
         {
             QueueClient.Publish(command);