Configured exponential retry

Author: jarmatys

API/SOFTURE.MessageBroker.Rabbit/DependencyInjection.cs

@@ -46,7 +46,8 @@ public static IServiceCollection AddCommonConsumers<TSettings>(
             this IServiceCollection services,
             Assembly assembly,
             int retryCount = 0,
-            int prefetchCount = 50)
+            int prefetchCount = 50,
+            bool exponentialRetry = false)
             where TSettings : IRabbitSettings
         {
             var consumerTypes = GetConsumers<IMessage>(assembly);
@@ -100,8 +101,22 @@ public static IServiceCollection AddCommonConsumers<TSettings>(
                             c.ConfigureConsumer(ctx, type);
                             c.PrefetchCount = prefetchCount;
 
-                            if (retryCount != 0)
-                                c.UseMessageRetry(r => r.Immediate(retryCount));
+                            switch (exponentialRetry)
+                            {
+                                case false when retryCount != 0:
+                                    c.UseMessageRetry(r => r.Immediate(retryCount));
+                                    break;
+                                case true when retryCount != 0:
+                                    c.UseMessageRetry(r =>
+                                    {
+                                        r.Exponential(
+                                            retryLimit: retryCount,
+                                            minInterval: TimeSpan.FromSeconds(1),
+                                            maxInterval: TimeSpan.FromMinutes(10),
+                                            intervalDelta: TimeSpan.FromSeconds(1));
+                                    });
+                                    break;
+                            }
                         }
                     });
                 });