fixup

Author: lukebakken

projects/Test/Integration/TestConnectionRecoveryWithoutSetup.cs

@@ -374,8 +374,6 @@ public async Task TestTopologyRecoveryConsumerFilter()
                     }
                     finally
                     {
-                        await ch.QueueDeleteAsync(queueWithRecoveredConsumer);
-                        await ch.QueueDeleteAsync(queueWithIgnoredConsumer);
                         await ch.CloseAsync();
                     }
                 }
@@ -387,22 +385,25 @@ public async Task TestTopologyRecoveryConsumerFilter()
         [Fact]
         public async Task TestRecoveryWithTopologyDisabled()
         {
+            string queueName = GenerateQueueName() + "-dotnet-client.test.recovery.q2";
+
             using (AutorecoveringConnection conn = await CreateAutorecoveringConnectionWithTopologyRecoveryDisabledAsync())
             {
                 using (IChannel ch = await conn.CreateChannelAsync())
                 {
                     try
                     {
-                        string s = "dotnet-client.test.recovery.q2";
-                        await ch.QueueDeleteAsync(s);
-                        await ch.QueueDeclareAsync(queue: s, durable: false, exclusive: true, autoDelete: false, arguments: null);
-                        await ch.QueueDeclareAsync(queue: s, passive: true, durable: false, exclusive: true, autoDelete: false, arguments: null);
+                        await ch.QueueDeleteAsync(queueName);
+                        await ch.QueueDeclareAsync(queue: queueName,
+                            durable: false, exclusive: true, autoDelete: false, arguments: null);
+                        await ch.QueueDeclareAsync(queue: queueName,
+                            passive: true, durable: false, exclusive: true, autoDelete: false, arguments: null);
 
                         Assert.True(ch.IsOpen);
                         await CloseAndWaitForRecoveryAsync(conn);
 
                         Assert.True(ch.IsOpen);
-                        await ch.QueueDeclareAsync(queue: s, passive: true, durable: false, exclusive: true, autoDelete: false, arguments: null);
+                        await ch.QueueDeclareAsync(queue: queueName, passive: true, durable: false, exclusive: true, autoDelete: false, arguments: null);
 
                         Assert.Fail("Expected an exception");
                     }