* Restore IsOpen check

rabbitmq · Apr 25, 2024 · 0c7cf52 · 0c7cf52
1 parent 77fc4ea
commit 0c7cf52
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -539,7 +539,10 @@ protected virtual void Dispose(bool disposing)
             {
                 try
                 {
-                    this.AbortAsync().GetAwaiter().GetResult();
+                    if (IsOpen)
+                    {
+                        this.AbortAsync().GetAwaiter().GetResult();
+                    }
                     ConsumerDispatcher.Dispose();
                     _rpcSemaphore.Dispose();
                     _confirmSemaphore?.Dispose();

diff --git a/projects/RabbitMQ.Client/client/impl/Connection.cs b/projects/RabbitMQ.Client/client/impl/Connection.cs
@@ -509,7 +509,10 @@ private void Dispose(bool disposing)
             {
                 try
                 {
-                    this.AbortAsync().GetAwaiter().GetResult();
+                    if (IsOpen)
+                    {
+                        this.AbortAsync().GetAwaiter().GetResult();
+                    }
                     _session0.Dispose();
                     _mainLoopCts.Dispose();
                     _sessionManager.Dispose();