Merge pull request #775 from danielmarbach/fix-async-consumer-loop

Fix AsyncConsumerWorkService

Author: michaelklishin

projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerWorkService.cs

@@ -45,7 +45,7 @@ class WorkPool
             readonly ModelBase _model;
             CancellationTokenRegistration _tokenRegistration;
             volatile TaskCompletionSource<bool> _syncSource = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
-            private Task _task;
+            private Task _worker;
 
             public WorkPool(ModelBase model)
             {
@@ -57,7 +57,7 @@ public WorkPool(ModelBase model)
 
             public void Start()
             {
-                _task = Task.Run(Loop, CancellationToken.None);
+                _worker = Task.Run(Loop, CancellationToken.None);
             }
 
             public void Enqueue(Work work)
@@ -80,7 +80,7 @@ async Task Loop()
                         // Swallowing the task cancellation in case we are stopping work.
                     }
 
-                    if (!_tokenSource.IsCancellationRequested && _workQueue.TryDequeue(out Work work))
+                    while (_tokenSource.IsCancellationRequested == false && _workQueue.TryDequeue(out Work work))
                     {
                         await work.Execute(_model).ConfigureAwait(false);
                     }