Why the heck does TestConcurrentQueueDeclareAndBindAsync fail sometimes

Author: lukebakken

projects/Test/Integration/TestQueueDeclare.cs

@@ -85,7 +85,7 @@ public async void TestConcurrentQueueDeclareAndBindAsync()
             };
 
             var tasks = new List<Task>();
-            var queueNames = new ConcurrentBag<string>();
+            var queueNames = new ConcurrentDictionary<string, bool>();
 
             NotSupportedException nse = null;
             for (int i = 0; i < 256; i++)
@@ -101,7 +101,10 @@ async Task f()
                             durable: false, exclusive: true, autoDelete: false);
                         string queueName = r.QueueName;
                         await _channel.QueueBindAsync(queue: queueName, exchange: "amq.fanout", routingKey: queueName);
-                        queueNames.Add(queueName);
+                        if (false == queueNames.TryAdd(queueName, true))
+                        {
+                            throw new InvalidOperationException($"queue with name {queueName} already added!");
+                        }
                     }
                     catch (NotSupportedException e)
                     {
@@ -117,7 +120,7 @@ async Task f()
             tasks.Clear();
 
             nse = null;
-            foreach (string q in queueNames)
+            foreach (string q in queueNames.Keys)
             {
                 async Task f()
                 {