Use the async disposable channel in the auto recover connection

Author: danielmarbach

projects/RabbitMQ.Client/Impl/AutorecoveringConnection.Recovery.cs

@@ -299,13 +299,12 @@ private async ValueTask RecoverExchangesAsync(IConnection connection,
             {
                 try
                 {
-                    using (IChannel ch = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false))
-                    {
-                        await recordedExchange.RecoverAsync(ch, cancellationToken)
-                            .ConfigureAwait(false);
-                        await ch.CloseAsync(cancellationToken)
-                            .ConfigureAwait(false);
-                    }
+                    var channel = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false);
+                    await using var _ = channel.ConfigureAwait(false);
+                    await recordedExchange.RecoverAsync(channel, cancellationToken)
+                        .ConfigureAwait(false);
+                    await channel.CloseAsync(cancellationToken)
+                        .ConfigureAwait(false);
                 }
                 catch (Exception ex)
                 {
@@ -351,11 +350,12 @@ private async Task RecoverQueuesAsync(IConnection connection,
                 try
                 {
                     string newName = string.Empty;
-                    using (IChannel ch = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false))
+                    var channel = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false);
+                    await using (channel.ConfigureAwait(false))
                     {
-                        newName = await recordedQueue.RecoverAsync(ch, cancellationToken)
+                        newName = await recordedQueue.RecoverAsync(channel, cancellationToken)
                             .ConfigureAwait(false);
-                        await ch.CloseAsync(cancellationToken)
+                        await channel.CloseAsync(cancellationToken)
                             .ConfigureAwait(false);
                     }
                     string oldName = recordedQueue.Name;
@@ -463,13 +463,12 @@ private async ValueTask RecoverBindingsAsync(IConnection connection,
             {
                 try
                 {
-                    using (IChannel ch = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false))
-                    {
-                        await binding.RecoverAsync(ch, cancellationToken)
-                            .ConfigureAwait(false);
-                        await ch.CloseAsync(cancellationToken)
-                            .ConfigureAwait(false);
-                    }
+                    var channel = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false);
+                    await using var _ = channel.ConfigureAwait(false);
+                    await binding.RecoverAsync(channel, cancellationToken)
+                        .ConfigureAwait(false);
+                    await channel.CloseAsync(cancellationToken)
+                        .ConfigureAwait(false);
                 }
                 catch (Exception ex)
                 {