Merge branch 'release/1.3.2'

MvRens · Aug 8, 2019 · 53dc0b7 · 53dc0b7
2 parents 442cfdf + d17f4f3
commit 53dc0b7
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/Tapeti/Connection/TapetiWorker.cs b/Tapeti/Connection/TapetiWorker.cs
@@ -34,6 +34,7 @@ public class TapetiWorker
 
         // These fields are for use in the taskQueue only!
         private RabbitMQ.Client.IConnection connection;
+        private bool isClosing;
         private bool isReconnect;
         private IModel channelInstance;
         private ulong lastDeliveryTag;
@@ -173,6 +174,8 @@ public Task Close()
 
             return taskQueue.Value.Add(() =>
             {
+                isClosing = true;
+
                 if (channelInstance != null)
                 {
                     channelInstance.Dispose();
@@ -371,6 +374,9 @@ private IModel GetChannel()
                         });
 
                         channelInstance = null;
+
+                        if (!isClosing)
+                            taskQueue.Value.Add(() => WithRetryableChannel(channel => { }));
                     };
 
                     channelInstance.BasicReturn += HandleBasicReturn;