Messaging

Author: phongnguyend

src/Monolith/ClassifiedAds.Background/appsettings.json

@@ -62,8 +62,9 @@
       },
       "Consumers": {
         "WebhookConsumer": {
-          //"Property_MaxRetryCount": 5,
-          //"Property_DeadLetterEnabled": true,
+          "MaxRetryCount": 5,
+          "RetryIntervals": "10, 30, 50, 80, 130, 210, 340",
+          "DeadLetterEnabled": true,
           "FileCreatedEvent": "webhook_classifiedadds_file_created",
           "FileUpdatedEvent": "webhook_classifiedadds_file_updated",
           "FileDeletedEvent": "webhook_classifiedadds_file_deleted",

src/Monolith/ClassifiedAds.Infrastructure/Messaging/MessagingCollectionExtensions.cs

@@ -81,6 +81,7 @@ public static IServiceCollection AddRabbitMQReceiver<TConsumer, T>(this IService
             AutomaticCreateEnabled = true,
             MessageEncryptionKey = options.MessageEncryptionKey,
             MaxRetryCount = options.GetMaxRetryCount(typeof(TConsumer).Name),
+            RetryIntervals = options.GetRetryIntervals(typeof(TConsumer).Name),
             DeadLetterEnabled = options.GetDeadLetterEnabled(typeof(TConsumer).Name)
         };
 

src/Monolith/ClassifiedAds.Infrastructure/Messaging/RabbitMQ/RabbitMQOptions.cs

@@ -1,4 +1,6 @@
-using System.Collections.Generic;
+using System;
+using System.Collections.Generic;
+using System.Linq;
 
 namespace ClassifiedAds.Infrastructure.Messaging.RabbitMQ;
 
@@ -35,11 +37,23 @@ public string TryGetProperty(string consumerName, string propertyName)
 
     public int GetMaxRetryCount(string consumerName)
     {
-        return int.TryParse(TryGetProperty(consumerName, "Property_MaxRetryCount"), out var maxRetryCount) ? maxRetryCount : 0;
+        return int.TryParse(TryGetProperty(consumerName, "MaxRetryCount"), out var maxRetryCount) ? maxRetryCount : 0;
     }
 
     public bool GetDeadLetterEnabled(string consumerName)
     {
-        return bool.TryParse(TryGetProperty(consumerName, "Property_DeadLetterEnabled"), out var deadLetterEnabled) ? deadLetterEnabled : false;
+        return bool.TryParse(TryGetProperty(consumerName, "DeadLetterEnabled"), out var deadLetterEnabled) ? deadLetterEnabled : false;
+    }
+
+    public int[] GetRetryIntervals(string consumerName)
+    {
+        var s = TryGetProperty(consumerName, "RetryIntervals");
+
+        if (string.IsNullOrWhiteSpace(s))
+        {
+            return [];
+        }
+
+        return [.. s.Split(',', StringSplitOptions.RemoveEmptyEntries).Select(int.Parse)];
     }
 }