Use unique queue and exchange names

Hopefully will address some test flakes in topology recovery.

Author: lukebakken

projects/Test/Integration/TestConnectionRecoveryWithoutSetup.cs

@@ -270,9 +270,9 @@ public async Task TestCreateChannelOnClosedAutorecoveringConnectionDoesNotHang()
         [Fact]
         public async Task TestTopologyRecoveryConsumerFilter()
         {
-            const string exchange = "topology.recovery.exchange";
-            const string queueWithRecoveredConsumer = "topology.recovery.queue.1";
-            const string queueWithIgnoredConsumer = "topology.recovery.queue.2";
+            string exchange = GenerateExchangeName();
+            string queueWithRecoveredConsumer = GenerateQueueName();
+            string queueWithIgnoredConsumer = GenerateQueueName();
             const string binding1 = "recovered.binding.1";
             const string binding2 = "recovered.binding.2";
 
@@ -357,6 +357,8 @@ public async Task TestTopologyRecoveryConsumerFilter()
                     }
                     finally
                     {
+                        await ch.QueueDeleteAsync(queueWithRecoveredConsumer);
+                        await ch.QueueDeleteAsync(queueWithIgnoredConsumer);
                         await ch.CloseAsync();
                     }
                 }

projects/Test/Integration/TestConnectionTopologyRecovery.cs

@@ -88,6 +88,9 @@ public async Task TestRecoverTopologyOnDisposedChannel()
         [Fact]
         public async Task TestTopologyRecoveryQueueFilter()
         {
+            string queueToRecover = GenerateQueueName();
+            string queueToIgnore = GenerateQueueName() + "-filtered.queue";
+
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var filter = new TopologyRecoveryFilter
@@ -99,8 +102,6 @@ public async Task TestTopologyRecoveryQueueFilter()
             conn.RecoverySucceeded += (source, ea) => tcs.SetResult(true);
             IChannel ch = await conn.CreateChannelAsync();
 
-            string queueToRecover = "recovered.queue";
-            string queueToIgnore = "filtered.queue";
             await ch.QueueDeclareAsync(queueToRecover, false, false, false);
             await ch.QueueDeclareAsync(queueToIgnore, false, false, false);
 
@@ -134,6 +135,9 @@ public async Task TestTopologyRecoveryQueueFilter()
         [Fact]
         public async Task TestTopologyRecoveryExchangeFilter()
         {
+            string exchangeToRecover = GenerateExchangeName();
+            string exchangeToIgnore = GenerateExchangeName() + "-filtered.exchange";
+
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var filter = new TopologyRecoveryFilter
@@ -146,8 +150,6 @@ public async Task TestTopologyRecoveryExchangeFilter()
             IChannel ch = await conn.CreateChannelAsync();
             try
             {
-                string exchangeToRecover = "recovered.exchange";
-                string exchangeToIgnore = "filtered.exchange";
                 await ch.ExchangeDeclareAsync(exchangeToRecover, "topic", false, true);
                 await ch.ExchangeDeclareAsync(exchangeToIgnore, "direct", false, true);
 
@@ -178,6 +180,12 @@ public async Task TestTopologyRecoveryExchangeFilter()
         [Fact]
         public async Task TestTopologyRecoveryBindingFilter()
         {
+            string exchange = GenerateExchangeName();
+            string queueWithRecoveredBinding = GenerateQueueName();
+            string queueWithIgnoredBinding = GenerateQueueName();
+            const string bindingToRecover = "recovered.binding";
+            const string bindingToIgnore = "filtered.binding";
+
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var filter = new TopologyRecoveryFilter
@@ -192,12 +200,6 @@ public async Task TestTopologyRecoveryBindingFilter()
 
             try
             {
-                string exchange = "topology.recovery.exchange";
-                string queueWithRecoveredBinding = "topology.recovery.queue.1";
-                string queueWithIgnoredBinding = "topology.recovery.queue.2";
-                string bindingToRecover = "recovered.binding";
-                string bindingToIgnore = "filtered.binding";
-
                 await ch.ExchangeDeclareAsync(exchange, "direct");
                 await ch.QueueDeclareAsync(queueWithRecoveredBinding, false, false, false);
                 await ch.QueueDeclareAsync(queueWithIgnoredBinding, false, false, false);
@@ -218,6 +220,9 @@ public async Task TestTopologyRecoveryBindingFilter()
             }
             finally
             {
+                await ch.ExchangeDeleteAsync(exchange);
+                await ch.QueueDeleteAsync(queueWithRecoveredBinding);
+                await ch.QueueDeleteAsync(queueWithIgnoredBinding);
                 await ch.CloseAsync();
                 await conn.CloseAsync();
                 ch.Dispose();
@@ -228,9 +233,9 @@ public async Task TestTopologyRecoveryBindingFilter()
         [Fact]
         public async Task TestTopologyRecoveryDefaultFilterRecoversAllEntities()
         {
-            const string exchange = "topology.recovery.exchange";
-            const string queue1 = "topology.recovery.queue.1";
-            const string queue2 = "topology.recovery.queue.2";
+            string exchange = GenerateExchangeName();
+            string queue1 = GenerateQueueName();
+            string queue2 = GenerateQueueName();
             const string binding1 = "recovered.binding";
             const string binding2 = "filtered.binding";
 
@@ -305,6 +310,9 @@ public async Task TestTopologyRecoveryDefaultFilterRecoversAllEntities()
         [Fact]
         public async Task TestTopologyRecoveryQueueExceptionHandler()
         {
+            string queueToRecoverWithException = GenerateQueueName() + "-recovery.exception.queue";
+            string queueToRecoverSuccessfully = GenerateQueueName() + "-successfully.recovered.queue";
+
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var changedQueueArguments = new Dictionary<string, object>
@@ -335,8 +343,6 @@ await channel.QueueDeclareAsync(rq.Name, false, false, false,
             conn.RecoverySucceeded += (source, ea) => tcs.SetResult(true);
             IChannel ch = await conn.CreateChannelAsync();
 
-            string queueToRecoverWithException = "recovery.exception.queue";
-            string queueToRecoverSuccessfully = "successfully.recovered.queue";
             await ch.QueueDeclareAsync(queueToRecoverWithException, false, false, false);
             await ch.QueueDeclareAsync(queueToRecoverSuccessfully, false, false, false);
 
@@ -367,6 +373,9 @@ await _channel.QueueDeclareAsync(queueToRecoverWithException, false, false, fals
         [Fact]
         public async Task TestTopologyRecoveryExchangeExceptionHandler()
         {
+            string exchangeToRecoverWithException = GenerateExchangeName() + "-recovery.exception.exchange";
+            string exchangeToRecoverSuccessfully = GenerateExchangeName() + "-successfully.recovered.exchange";
+
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var exceptionHandler = new TopologyRecoveryExceptionHandler
@@ -390,8 +399,6 @@ public async Task TestTopologyRecoveryExchangeExceptionHandler()
             AutorecoveringConnection conn = await CreateAutorecoveringConnectionWithTopologyRecoveryExceptionHandlerAsync(exceptionHandler);
             conn.RecoverySucceeded += (source, ea) => tcs.SetResult(true);
 
-            string exchangeToRecoverWithException = "recovery.exception.exchange";
-            string exchangeToRecoverSuccessfully = "successfully.recovered.exchange";
             IChannel ch = await conn.CreateChannelAsync();
             await ch.ExchangeDeclareAsync(exchangeToRecoverWithException, "direct", false, false);
             await ch.ExchangeDeclareAsync(exchangeToRecoverSuccessfully, "direct", false, false);
@@ -423,12 +430,12 @@ public async Task TestTopologyRecoveryExchangeExceptionHandler()
         [Fact]
         public async Task TestTopologyRecoveryBindingExceptionHandler()
         {
-            var connectionRecoveryTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
-
-            const string exchange = "topology.recovery.exchange";
-            const string queueWithExceptionBinding = "recovery.exception.queue";
+            string exchange = GenerateExchangeName();
+            string queueWithExceptionBinding = GenerateQueueName();
             const string bindingToRecoverWithException = "recovery.exception.binding";
 
+            var connectionRecoveryTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
+
             var exceptionHandler = new TopologyRecoveryExceptionHandler
             {
                 BindingRecoveryExceptionCondition = (b, ex) =>
@@ -484,9 +491,9 @@ public async Task TestTopologyRecoveryBindingExceptionHandler()
         [Fact]
         public async Task TestTopologyRecoveryConsumerExceptionHandler()
         {
-            var connectionRecoveryTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
+            string queueWithExceptionConsumer = GenerateQueueName() + "-recovery.exception.queue";
 
-            string queueWithExceptionConsumer = "recovery.exception.queue";
+            var connectionRecoveryTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var exceptionHandler = new TopologyRecoveryExceptionHandler
             {