support multiple exchanges

changelog.md

@@ -1,4 +1,9 @@
 # Changelog
+## [5.0.0] - 2026-05-12
+### *Changes (Breaking)*
+- Target .NET 10
+- Add optional additionalBindings parameter to RabbitChannelConfiguration, allowing a consumer queue to bind to multiple external exchanges with specific routing keys
+- Add ExchangeBinding record type
 ## [4.0.1] - 2026-04-02
 ### *Changes
 - Add optional exchangeType parameter to RabbitChannelConfiguration

src/ExchangeBinding.cs

@@ -0,0 +1,3 @@
+namespace Linn.Common.Messaging.RabbitMQ;
+
+public record ExchangeBinding(string ExchangeName, string[] RoutingKeys);

src/Linn.Common.Messaging.RabbitMQ.csproj

@@ -1,11 +1,11 @@
 <Project Sdk="Microsoft.NET.Sdk">
 	<PropertyGroup>
 		<Description>Utilities for requesting data from other (proxy) services.</Description>
-		<TargetFramework>net9.0</TargetFramework>
+		<TargetFramework>net10.0</TargetFramework>
 		<ImplicitUsings>enable</ImplicitUsings>
 		<AssemblyName>Linn.Common.Messaging.RabbitMQ</AssemblyName>
 		<PackageId>Linn.Common.Messaging.RabbitMQ</PackageId>
-		<Version>4.0.1</Version>
+		<Version>5.0.0</Version>
 	  <Nullable>enable</Nullable>
 	</PropertyGroup>
 	<ItemGroup>

src/RabbitChannelConfiguration.cs

@@ -12,7 +12,8 @@
     string? dlxName = null,
     bool createProducerChannel = true,
     bool createConsumerChannel = true,
-    string exchangeType = ExchangeType.Direct)
+    string exchangeType = ExchangeType.Direct,
+    ExchangeBinding[]? additionalBindings = null)
     : IAsyncDisposable
 {
     private readonly string dlqName = string.IsNullOrEmpty(dlqName) ? queueName : dlqName;
@@ -33,10 +34,10 @@
     {
         var factory = new ConnectionFactory
         {
             HostName = ConfigurationManager.Configuration["RABBIT_SERVER"], 
             UserName = ConfigurationManager.Configuration["RABBIT_USERNAME"],
             Password = ConfigurationManager.Configuration["RABBIT_PASSWORD"],
             Port = int.Parse(ConfigurationManager.Configuration["RABBIT_PORT"])
         };
 
         this.Connection = await factory.CreateConnectionAsync(cancellationToken);
@@ -99,7 +100,7 @@
                 durable: true,
                 exclusive: false,
                 autoDelete: false,
                 arguments: args,
                 cancellationToken: cancellationToken);
 
             foreach (var routingKey in routingKeys)
@@ -112,6 +113,23 @@
                     noWait: false,
                     cancellationToken: cancellationToken);
             }
+
+            if (additionalBindings != null)
+            {
+                foreach (var binding in additionalBindings)
+                {
+                    foreach (var routingKey in binding.RoutingKeys)
+                    {
+                        await setupChannel.QueueBindAsync(
+                            queue: $"{queueName}.q",
+                            exchange: $"{binding.ExchangeName}.x",
+                            routingKey: routingKey,
+                            arguments: null,
+                            noWait: false,
+                            cancellationToken: cancellationToken);
+                    }
+                }
+            }
         }
     }