Show failure queue length in queue:length command

Author: ethanhann

src/InEngine.Core/Queue/Broker.cs

@@ -114,6 +114,11 @@ public long GetPrimaryProcessingQueueLength()
             return Redis.ListLength(PrimaryProcessingQueueName);
         }
 
+        public long GetPrimaryFailedQueueLength()
+        {
+            return Redis.ListLength(PrimaryFailedQueueName);
+        }
+
         public bool ClearPrimaryWaitingQueue()
         {
             return Redis.KeyDelete(PrimaryWaitingQueueName);
@@ -136,6 +141,11 @@ public long GetSecondaryProcessingQueueLength()
             return Redis.ListLength(SecondaryProcessingQueueName);
         }
 
+        public long GetSecondaryFailedQueueLength()
+        {
+            return Redis.ListLength(SecondaryFailedQueueName);
+        }
+
         public bool ClearSecondaryWaitingQueue()
         {
             return Redis.KeyDelete(SecondaryWaitingQueueName);

src/InEngine.Core/Queue/Commands/GetLength.cs renamed to src/InEngine.Core/Queue/Commands/Length.cs

@@ -3,7 +3,7 @@
 
 namespace InEngine.Core.Queue.Commands
 {
-    public class GetLength : AbstractCommand
+    public class Length : AbstractCommand
     {
         public override void Run()
         {
@@ -14,13 +14,17 @@ public override void Run()
             Line(broker.GetPrimaryWaitingQueueLength().ToString().PadLeft(10));
             InfoText("In-progress".PadLeft(leftPadding));
             Line(broker.GetPrimaryProcessingQueueLength().ToString().PadLeft(10));
+            ErrorText("Failed".PadLeft(leftPadding));
+            Line(broker.GetPrimaryProcessingQueueLength().ToString().PadLeft(10));
             Newline();
 
             Warning("Secondary Queue:");
             InfoText("Pending".PadLeft(leftPadding));
             Line(broker.GetSecondaryWaitingQueueLength().ToString().PadLeft(10));
             InfoText("In-progress".PadLeft(leftPadding));
             Line(broker.GetSecondaryProcessingQueueLength().ToString().PadLeft(10));
+            ErrorText("Failed".PadLeft(leftPadding));
+            Line(broker.GetSecondaryProcessingQueueLength().ToString().PadLeft(10));
             Newline();
         }
     }

src/InEngine.Core/Queue/Options.cs

@@ -7,13 +7,13 @@ namespace InEngine.Core.Queue
     public class Options : IOptions
     {
         [VerbOption("queue:publish", HelpText = "Publish a command message to a queue.")]
-        public Publish QueuePublish { get; set; }
+        public Publish Publish { get; set; }
 
         [VerbOption("queue:consume", HelpText = "Consume one or more command messages from the queue.")]
-        public Consume QueueConsume { get; set; }
+        public Consume Consume { get; set; }
 
         [VerbOption("queue:length", HelpText = "Get the number of messages in the primary and secondary queues.")]
-        public GetLength QueueGetLength { get; set; }
+        public Length Length { get; set; }
 
         [VerbOption("queue:clear", HelpText = "Clear the primary and secondary queues.")]
         public ClearAll QueueClearAll { get; set; }