Messaging

Author: phongnguyend

src/Monolith/ClassifiedAds.Background/appsettings.json

@@ -62,6 +62,8 @@
       },
       "Consumers": {
         "WebhookConsumer": {
+          //"Property_MaxRetryCount": 5,
+          //"Property_DeadLetterEnabled": true,
           "FileCreatedEvent": "webhook_classifiedadds_file_created",
           "FileUpdatedEvent": "webhook_classifiedadds_file_updated",
           "FileDeletedEvent": "webhook_classifiedadds_file_deleted",

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

@@ -79,7 +79,9 @@ public static IServiceCollection AddRabbitMQReceiver<TConsumer, T>(this IService
             RoutingKey = options.RoutingKeys[typeof(T).Name],
             QueueName = options.Consumers[typeof(TConsumer).Name][typeof(T).Name],
             AutomaticCreateEnabled = true,
-            MessageEncryptionKey = options.MessageEncryptionKey
+            MessageEncryptionKey = options.MessageEncryptionKey,
+            MaxRetryCount = options.GetMaxRetryCount(typeof(TConsumer).Name),
+            DeadLetterEnabled = options.GetDeadLetterEnabled(typeof(TConsumer).Name)
         };
 
         services.AddTransient<IMessageReceiver<TConsumer, T>>(x => new RabbitMQReceiver<TConsumer, T>(receiverOptions, x.GetRequiredService<ILogger<RabbitMQReceiver<TConsumer, T>>>()));

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

@@ -27,4 +27,19 @@ public string ConnectionString
     public bool MessageEncryptionEnabled { get; set; }
 
     public string MessageEncryptionKey { get; set; }
+
+    public string TryGetProperty(string consumerName, string propertyName)
+    {
+        return Consumers[consumerName].TryGetValue(propertyName, out var value) ? value : null;
+    }
+
+    public int GetMaxRetryCount(string consumerName)
+    {
+        return int.TryParse(TryGetProperty(consumerName, "Property_MaxRetryCount"), out var maxRetryCount) ? maxRetryCount : 0;
+    }
+
+    public bool GetDeadLetterEnabled(string consumerName)
+    {
+        return bool.TryParse(TryGetProperty(consumerName, "Property_DeadLetterEnabled"), out var deadLetterEnabled) ? deadLetterEnabled : false;
+    }
 }

tools/mssqlserver-2025/docker-compose.yml

@@ -1,6 +1,6 @@
 services:
   db:
-    image: 'mcr.microsoft.com/mssql/server:2022-latest'
+    image: 'mcr.microsoft.com/mssql/server:2025-latest'
     ports:
       - '1433:1433'
     environment: