Fix Argument exception is thrown on dispose of consumer dispatcher (#…

…1096)
EasyNetQ · Aug 10, 2020 · e3ce0ba · e3ce0ba
1 parent 4268063
commit e3ce0ba
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs b/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs
@@ -26,10 +26,10 @@ public ConsumerDispatcher()
                     while (!cancellation.IsCancellationRequested)
                         try
                         {
-                            BlockingCollection<Action>.TakeFromAny(
-                                blockingCollections, out var action, cancellation.Token
-                            );
-                            action();
+                            if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, -1, cancellation.Token) >= 0)
+                            {
+                                action();
+                            }
                         }
                         catch (OperationCanceledException) when (cancellation.IsCancellationRequested)
                         {