* Do not use the amq.fanout fanout exchange because messages published to it could end up in tests that should note have messages, like TestConcurrentQueueDeclareAndBindAsync

Author: lukebakken

projects/Test/Integration/TestConfirmSelect.cs

@@ -29,6 +29,7 @@
 //  Copyright (c) 2007-2020 VMware, Inc.  All rights reserved.
 //---------------------------------------------------------------------------
 
+using System;
 using System.Threading.Tasks;
 using RabbitMQ.Client;
 using Xunit;
@@ -47,7 +48,8 @@ public async Task TestConfirmSelectIdempotency()
         {
             ValueTask PublishAsync()
             {
-                return _channel.BasicPublishAsync("", "amq.fanout", _encoding.GetBytes("message"));
+                return _channel.BasicPublishAsync(exchange: "",
+                    routingKey: Guid.NewGuid().ToString(), _encoding.GetBytes("message"));
             }
 
             await _channel.ConfirmSelectAsync();

projects/Test/Integration/TestConfirmSelectAsync.cs

@@ -29,6 +29,7 @@
 //  Copyright (c) 2007-2020 VMware, Inc.  All rights reserved.
 //---------------------------------------------------------------------------
 
+using System;
 using System.Threading.Tasks;
 using RabbitMQ.Client;
 using Xunit;
@@ -65,7 +66,8 @@ public async Task TestConfirmSelectIdempotency()
 
         private ValueTask Publish()
         {
-            return _channel.BasicPublishAsync("", "amq.fanout", _message);
+            return _channel.BasicPublishAsync(exchange: "",
+                routingKey: Guid.NewGuid().ToString(), _message);
         }
     }
 }

projects/Test/Integration/TestQueueDeclare.cs

@@ -87,6 +87,10 @@ public async void TestConcurrentQueueDeclareAndBindAsync()
             var tasks = new List<Task>();
             var queueNames = new ConcurrentDictionary<string, bool>();
 
+            string exchangeName = GenerateExchangeName();
+            await _channel.ExchangeDeclareAsync(exchange: exchangeName, ExchangeType.Fanout,
+                durable: false, autoDelete: true);
+
             NotSupportedException nse = null;
             for (int i = 0; i < 256; i++)
             {
@@ -101,7 +105,8 @@ async Task f()
                         QueueDeclareOk r = await _channel.QueueDeclareAsync(queue: queueName,
                             durable: false, exclusive: true, autoDelete: false);
                         Assert.Equal(queueName, r.QueueName);
-                        await _channel.QueueBindAsync(queue: queueName, exchange: "amq.fanout", routingKey: queueName);
+                        await _channel.QueueBindAsync(queue: queueName,
+                            exchange: exchangeName, routingKey: queueName);
                         if (false == queueNames.TryAdd(queueName, true))
                         {
                             throw new InvalidOperationException($"queue with name {queueName} already added!");
@@ -134,7 +139,8 @@ async Task f()
                         Assert.Equal(qname, r.QueueName);
                         Assert.Equal((uint)0, r.MessageCount);
 
-                        await _channel.QueueUnbindAsync(queue: qname, exchange: "amq.fanout", routingKey: qname, null);
+                        await _channel.QueueUnbindAsync(queue: qname,
+                            exchange: exchangeName, routingKey: qname, null);
 
                         uint deletedMessageCount = await _channel.QueueDeleteAsync(qname, false, false);
                         Assert.Equal((uint)0, deletedMessageCount);

projects/Test/SequentialIntegration/SequentialIntegrationFixture.cs

@@ -47,7 +47,8 @@ public async Task BlockAsync(IChannel channel)
             await _rabbitMQCtl.ExecRabbitMQCtlAsync("set_vm_memory_high_watermark 0.000000001");
             // give rabbitmqctl some time to do its job
             await Task.Delay(TimeSpan.FromSeconds(5));
-            await channel.BasicPublishAsync("amq.fanout", "", _encoding.GetBytes("message"));
+            await channel.BasicPublishAsync(exchange: "amq.direct",
+                routingKey: Guid.NewGuid().ToString(), _encoding.GetBytes("message"));
         }
 
         public Task UnblockAsync()