Merge pull request #23016 from moormaster/fix/issue-23015-cast-rabbitmq-queue-arguments

fix: ensure RabbitMQ QueueArguments from appsettings are parsed into correct types

framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/AbpEventBusRabbitMqModule.cs

@@ -1,4 +1,6 @@
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using Microsoft.Extensions.Options;
 using Volo.Abp.Modularity;
 using Volo.Abp.RabbitMQ;
 
@@ -12,8 +14,8 @@ public class AbpEventBusRabbitMqModule : AbpModule
     public override void ConfigureServices(ServiceConfigurationContext context)
     {
         var configuration = context.Services.GetConfiguration();
-
         Configure<AbpRabbitMqEventBusOptions>(configuration.GetSection("RabbitMQ:EventBus"));
+        context.Services.TryAddEnumerable(ServiceDescriptor.Singleton<IPostConfigureOptions<AbpRabbitMqEventBusOptions>, PostConfigureAbpRabbitMqEventBusOptions>());
     }
 
     public override void OnApplicationInitialization(ApplicationInitializationContext context)

framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/PostConfigureAbpRabbitMqEventBusOptions.cs

@@ -0,0 +1,54 @@
+using System.Collections.Generic;
+using Microsoft.Extensions.Options;
+
+namespace Volo.Abp.EventBus.RabbitMq;
+
+public class PostConfigureAbpRabbitMqEventBusOptions : IPostConfigureOptions<AbpRabbitMqEventBusOptions>
+{
+    private readonly HashSet<string> _uint64QueueArguments =
+    [
+        "x-delivery-limit",
+        "x-expires",
+        "x-message-ttl",
+        "x-max-length",
+        "x-max-length-bytes",
+        "x-quorum-initial-group-size",
+        "x-quorum-target-group-size",
+        "x-stream-filter-size-bytes",
+        "x-stream-max-segment-size-bytes",
+    ];
+
+    private readonly HashSet<string> _boolQueueArguments =
+    [
+        "x-single-active-consumer"
+    ];
+
+    public virtual void PostConfigure(string? name, AbpRabbitMqEventBusOptions options)
+    {
+        ParseBoolQueueArguments(options);
+        ParseIntegerQueueArguments(options);
+    }
+
+    protected virtual void ParseBoolQueueArguments(AbpRabbitMqEventBusOptions options)
+    {
+        foreach (var argument in _boolQueueArguments)
+        {
+            if (options.QueueArguments.TryGetValue(argument, out var value) && value is string stringValue && bool.TryParse(stringValue, out var boolValue))
+            {
+                options.QueueArguments[argument] = boolValue;
+            }
+        }
+    }
+
+    protected virtual void ParseIntegerQueueArguments(AbpRabbitMqEventBusOptions options)
+    {
+        foreach (var argument in _uint64QueueArguments)
+        {
+            if (options.QueueArguments.TryGetValue(argument, out var value) && value is string stringValue && int.TryParse(stringValue, out var intValue))
+            {
+                options.QueueArguments[argument] = intValue;
+            }
+        }
+    }
+
+}