Ensure that disposable instances are always disposed.

Fixes #1808 (hopefully)

Author: lukebakken

projects/RabbitMQ.Client/Impl/AutorecoveringChannel.cs

@@ -283,11 +283,17 @@ public async ValueTask DisposeAsync()
                     await this.AbortAsync()
                         .ConfigureAwait(false);
                 }
-
-                _recordedConsumerTags.Clear();
             }
             finally
             {
+                try
+                {
+                    _recordedConsumerTags.Clear();
+                }
+                catch
+                {
+                }
+
                 _disposed = true;
             }
         }

projects/RabbitMQ.Client/Impl/AutorecoveringConnection.cs

@@ -296,18 +296,24 @@ public async ValueTask DisposeAsync()
             {
                 await _innerConnection.DisposeAsync()
                     .ConfigureAwait(false);
-
-                _channels.Clear();
-                _recordedEntitiesSemaphore.Dispose();
-                _channelsSemaphore.Dispose();
-                _recoveryCancellationTokenSource.Dispose();
             }
             catch (OperationInterruptedException)
             {
                 // ignored, see rabbitmq/rabbitmq-dotnet-client#133
             }
             finally
             {
+                try
+                {
+                    _channels.Clear();
+                    _recordedEntitiesSemaphore.Dispose();
+                    _channelsSemaphore.Dispose();
+                    _recoveryCancellationTokenSource.Dispose();
+                }
+                catch
+                {
+                }
+
                 _disposed = true;
             }
         }

projects/RabbitMQ.Client/Impl/Channel.cs

@@ -573,15 +573,23 @@ protected virtual void Dispose(bool disposing)
                         this.AbortAsync().GetAwaiter().GetResult();
                     }
 
-                    _serverOriginatedChannelCloseTcs?.Task.Wait(TimeSpan.FromSeconds(5));
+                    _serverOriginatedChannelCloseTcs?.Task.Wait(InternalConstants.DefaultChannelDisposeTimeout);
 
                     ConsumerDispatcher.Dispose();
-                    _rpcSemaphore.Dispose();
-                    _confirmSemaphore.Dispose();
+
                     _outstandingPublisherConfirmationsRateLimiter?.Dispose();
                 }
                 finally
                 {
+                    try
+                    {
+                        _rpcSemaphore.Dispose();
+                        _confirmSemaphore.Dispose();
+                    }
+                    catch
+                    {
+                    }
+
                     _disposed = true;
                 }
             }
@@ -622,13 +630,11 @@ await this.AbortAsync()
 
                 if (_serverOriginatedChannelCloseTcs is not null)
                 {
-                    await _serverOriginatedChannelCloseTcs.Task.WaitAsync(TimeSpan.FromSeconds(5))
+                    await _serverOriginatedChannelCloseTcs.Task.WaitAsync(InternalConstants.DefaultChannelDisposeTimeout)
                         .ConfigureAwait(false);
                 }
 
                 ConsumerDispatcher.Dispose();
-                _rpcSemaphore.Dispose();
-                _confirmSemaphore.Dispose();
 
                 if (_outstandingPublisherConfirmationsRateLimiter is not null)
                 {
@@ -638,6 +644,15 @@ await _outstandingPublisherConfirmationsRateLimiter.DisposeAsync()
             }
             finally
             {
+                try
+                {
+                    _rpcSemaphore.Dispose();
+                    _confirmSemaphore.Dispose();
+                }
+                catch
+                {
+                }
+
                 _disposed = true;
             }
         }

projects/RabbitMQ.Client/Impl/Connection.cs

@@ -550,7 +550,14 @@ await _channel0.DisposeAsync()
             }
             finally
             {
-                _mainLoopCts.Dispose();
+                try
+                {
+                    _mainLoopCts.Dispose();
+                }
+                catch
+                {
+                }
+
                 _disposed = true;
             }
         }

projects/RabbitMQ.Client/InternalConstants.cs

@@ -37,6 +37,7 @@ internal static class InternalConstants
     {
         internal static readonly TimeSpan DefaultConnectionAbortTimeout = TimeSpan.FromSeconds(5);
         internal static readonly TimeSpan DefaultConnectionCloseTimeout = TimeSpan.FromSeconds(30);
+        internal static readonly TimeSpan DefaultChannelDisposeTimeout = TimeSpan.FromSeconds(5);
 
         /// <summary>
         /// Largest message size, in bytes, allowed in RabbitMQ.