Fixed consumers after reconnect

2019-09-10 19:01:01 +02:00 · 2019-09-10 19:01:01 +02:00 · 74ad8fb43e
parent 70f394f7fe
commit 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());
        }