Fix bug in the code that did not set certain PublishReturnException data

Author: lukebakken

projects/RabbitMQ.Client/Impl/Channel.PublisherConfirms.cs

@@ -223,7 +223,8 @@ private void HandleNack(ulong deliveryTag, bool multiple, bool isReturn,
                 {
                     if (_confirmsTaskCompletionSources.Remove(deliveryTag, out TaskCompletionSource<bool>? tcs))
                     {
-                        PublishException ex = PublishExceptionFactory.Create(isReturn, deliveryTag);
+                        PublishException ex = PublishExceptionFactory.Create(isReturn, deliveryTag,
+                            exchange, routingKey, replyCode, replyText);
                         tcs.SetException(ex);
                     }
                 }

projects/Test/Integration/TestBasicPublishAsync.cs

@@ -29,8 +29,10 @@
 //  Copyright (c) 2007-2025 Broadcom. All Rights Reserved.
 //---------------------------------------------------------------------------
 
+using System;
 using System.Threading.Tasks;
 using RabbitMQ.Client;
+using RabbitMQ.Client.Exceptions;
 using Xunit;
 using Xunit.Abstractions;
 
@@ -49,7 +51,6 @@ public async Task TestQueuePurgeAsync()
 
             var publishSyncSource = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
-
             QueueDeclareOk q = await _channel.QueueDeclareAsync(string.Empty, false, false, true);
 
             var publishTask = Task.Run(async () =>
@@ -65,5 +66,23 @@ public async Task TestQueuePurgeAsync()
             Assert.True(await publishSyncSource.Task);
             Assert.Equal((uint)messageCount, await _channel.QueuePurgeAsync(q));
         }
+
+        [Fact]
+        public async Task TestBasicReturnAsync()
+        {
+            try
+            {
+                await _channel.BasicPublishAsync(exchange: string.Empty, routingKey: Guid.NewGuid().ToString(),
+                    mandatory: true, body: GetRandomBody());
+            }
+            catch (PublishReturnException prex)
+            {
+                Assert.True(prex.IsReturn);
+                Assert.NotNull(prex.Exchange);
+                Assert.NotNull(prex.RoutingKey);
+                Assert.NotEqual(0, prex.ReplyCode);
+                Assert.NotNull(prex.ReplyText);
+            }
+        }
     }
 }

projects/Test/Integration/TestConcurrentAccessWithSharedChannel.cs

@@ -145,8 +145,13 @@ await TestConcurrentOperationsAsync(async () =>
                     }
                     catch (PublishException ex)
                     {
-                        if (ex.IsReturn)
+                        if (ex is PublishReturnException prex)
                         {
+                            Assert.True(prex.IsReturn);
+                            Assert.NotNull(prex.Exchange);
+                            Assert.NotNull(prex.RoutingKey);
+                            Assert.NotEqual(0, prex.ReplyCode);
+                            Assert.NotNull(prex.ReplyText);
                             Interlocked.Increment(ref totalReturnCount);
                         }
                         else