Fix test as noted by @qrli

Author: lukebakken

projects/Test/Integration/TestAsyncConsumerCancellation.cs

@@ -29,6 +29,7 @@ public async Task TestConsumerCancellation()
             var tcsShutdownCancelled = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
 
             var consumer = new AsyncEventingBasicConsumer(_channel);
+
             consumer.ShutdownAsync += async (model, ea) =>
             {
                 try
@@ -40,6 +41,7 @@ public async Task TestConsumerCancellation()
                     tcsShutdownCancelled.SetResult(true);
                 }
             };
+
             consumer.ReceivedAsync += async (model, ea) =>
             {
                 tcsMessageReceived.SetResult(true);
@@ -52,6 +54,7 @@ public async Task TestConsumerCancellation()
                     tcsReceivedCancelled.SetResult(true);
                 }
             };
+
             await _channel.BasicConsumeAsync(queueName, false, consumer);
 
             //publisher
@@ -65,8 +68,8 @@ await publisherChannel.BasicPublishAsync(exchange: exchangeName, routingKey: str
 
             await _channel.CloseAsync();
 
-            await WaitAsync(tcsMessageReceived, TimeSpan.FromSeconds(5), "Consumer closed");
-            await WaitAsync(tcsShutdownCancelled, TimeSpan.FromSeconds(5), "Consumer closed");
+            await WaitAsync(tcsReceivedCancelled, TimeSpan.FromSeconds(5), "ReceivedAsync cancelled");
+            await WaitAsync(tcsShutdownCancelled, TimeSpan.FromSeconds(5), "ShutdownAsync cancellation");
         }
     }
 }