Add support for auto-retrying after exception in main RunLoop thread

Author: mythz

src/ServiceStack.Redis/Messaging/RedisMqServer.cs

@@ -35,6 +35,8 @@ public class RedisMqServer : IMessageService
 
         public int RetryCount { get; protected set; }
 
+        public int? KeepAliveRetryAfterMs { get; set; }
+
         public IMessageFactory MessageFactory { get; private set; }
 
         public Func<string, IOneWayClient> ReplyClientFactory { get; set; }
@@ -111,6 +113,7 @@ public RedisMqServer(IRedisClientsManager clientsManager,
             //this.RequestTimeOut = requestTimeOut;
             this.MessageFactory = new RedisMessageFactory(clientsManager);
             this.ErrorHandler = ex => Log.Error("Exception in Redis MQ Server: " + ex.Message, ex);
+            this.KeepAliveRetryAfterMs = 2000;
         }
 
         public void RegisterHandler<T>(Func<IMessage<T>, object> processMessageFn)
@@ -314,6 +317,13 @@ private void RunLoop()
 
                 if (this.ErrorHandler != null) 
                     this.ErrorHandler(ex);
+
+
+                if (KeepAliveRetryAfterMs != null)
+                {
+                    Thread.Sleep(KeepAliveRetryAfterMs.Value);
+                    Start();
+                }
             }
         }
 

src/TestMqHost/Program.cs

@@ -19,7 +19,7 @@ class Program
         static void Main(string[] args)
         {
 
-            LogManager.LogFactory = new ConsoleLogFactory();
+            //LogManager.LogFactory = new ConsoleLogFactory();
             var log = LogManager.GetLogger(typeof(Program));
 
             var clientManager = new PooledRedisClientManager(new[] { "localhost" })
@@ -29,12 +29,14 @@ static void Main(string[] args)
 
             var mqHost = new RedisMqServer(clientManager, retryCount: 2);
 
+            var msgsProcessed = 0;
             var sum = 0;
             mqHost.RegisterHandler<Incr>(c =>
             {
                 var dto = c.GetBody();
                 sum += dto.Value;
                 log.InfoFormat("Received {0}, sum: {1}", dto.Value, sum);
+                msgsProcessed++;
                 return null;
             });
 
@@ -100,6 +102,10 @@ static void Main(string[] args)
 
                 Thread.Sleep(1000);
             });
+
+            Thread.Sleep(2000);
+            "Messages processed: {0}".Print(msgsProcessed);
+            Console.ReadKey();
         }
     }
 }