remove x-dead-letter-routing-key to preserve original routing key on …

changelog.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## [6.0.1] - 2026-08-25
+### *Bug Fix*
+- Remove `x-dead-letter-routing-key` from main queue arguments. Previously set to `""`, this caused RabbitMQ to overwrite the original routing key on dead-letter, making messages unroutable when requeued from the DLQ back to the original exchange. The original routing key is now preserved automatically.
+- **Deployment note:** Any existing `.q` queue declared with this library must be deleted and recreated for this change to take effect. RabbitMQ will throw 406 PRECONDITION_FAILED if the queue already exists with the old arguments.
+
 ## [6.0.0] - 2026-05-28
 ### *Changes (Breaking)*
 - RabbitMessageRouter now takes `IServiceProvider` instead of `IEnumerable<IMessageHandler>` and creates a DI scope per received message. This ensures scoped services (e.g. DbContext) are fresh for each message, preventing stale tracked entities from leaking across messages.

src/Linn.Common.Messaging.RabbitMQ.csproj

@@ -5,7 +5,7 @@
 		<ImplicitUsings>enable</ImplicitUsings>
 		<AssemblyName>Linn.Common.Messaging.RabbitMQ</AssemblyName>
 		<PackageId>Linn.Common.Messaging.RabbitMQ</PackageId>
-		<Version>6.0.0</Version>
+		<Version>6.0.1</Version>
 	  <Nullable>enable</Nullable>
 	</PropertyGroup>
 	<ItemGroup>

src/RabbitChannelConfiguration.cs

@@ -34,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);
@@ -91,8 +91,7 @@
 
             var args = new Dictionary<string, object>
             {
-                { "x-dead-letter-exchange", $"{this.dlxName}.dlx" },
-                { "x-dead-letter-routing-key", string.Empty }
+                { "x-dead-letter-exchange", $"{this.dlxName}.dlx" }
             };
 
             await setupChannel.QueueDeclareAsync(
@@ -100,7 +99,7 @@
                 durable: true,
                 exclusive: false,
                 autoDelete: false,
                 arguments: args,
                 cancellationToken: cancellationToken);
 
             foreach (var routingKey in routingKeys)