fixup

Author: lukebakken

projects/Test/Integration/ConnectionRecovery/TestConnectionRecovery.cs

@@ -42,7 +42,8 @@ namespace Test.Integration.ConnectionRecovery
 {
     public class TestConnectionRecovery : TestConnectionRecoveryBase
     {
-        public TestConnectionRecovery(ITestOutputHelper output) : base(output)
+        public TestConnectionRecovery(ITestOutputHelper output)
+            : base(output, dispatchConsumersAsync: true)
         {
         }
 
@@ -60,8 +61,9 @@ Task MessageReceived(object sender, BasicDeliverEventArgs e)
                 return Task.CompletedTask;
             }
 
-            string exchangeName = $"ex-gh-1035-{Guid.NewGuid()}";
-            string queueName = $"q-gh-1035-{Guid.NewGuid()}";
+            var guid = Guid.NewGuid();
+            string exchangeName = $"ex-gh-1035-{guid}";
+            string queueName = $"q-gh-1035-{guid}";
 
             await _channel.ExchangeDeclareAsync(exchange: exchangeName,
                 type: "fanout", durable: false, autoDelete: true,
@@ -78,6 +80,9 @@ await _channel.ExchangeDeclareAsync(exchange: exchangeName,
 
             _channel = await _conn.CreateChannelAsync();
 
+            // NB: add this for debugging
+            // AddCallbackHandlers();
+
             await _channel.ExchangeDeclareAsync(exchange: exchangeName,
                 type: "fanout", durable: false, autoDelete: true,
                 arguments: null);