Merge branch 'release/1.3.3'

2024-11-21 08:53:50 +00:00 · 2019-09-10 19:01:32 +02:00 · 2019-09-10 19:01:32 +02:00 · 8888af3d0f
commit 8888af3d0f
parent 53dc0b79f1 74ad8fb43e
1 changed files with 5 additions and 2 deletions
--- a/Tapeti/Connection/TapetiSubscriber.cs
+++ b/Tapeti/Connection/TapetiSubscriber.cs
@ -26,9 +26,12 @@ namespace Tapeti.Connection
        }


-        public Task RebindQueues()
+        public async Task RebindQueues()
        {
-            return BindQueues();
+            await BindQueues();
+
+            if (consuming)
+                await Task.WhenAll(queues.Select(queue => workerFactory().Consume(queue.Name, queue.Bindings)).ToList());
        }