Merge tag '1.3.3' into develop

2024-11-21 08:53:50 +00:00 · 2019-09-10 19:01:32 +02:00 · 2019-09-10 19:01:32 +02:00 · 3f9b79403a
commit 3f9b79403a
parent 70f394f7fe 8888af3d0f
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());
        }