Fixing after reviews.

rabbitmq · Feb 19, 2021 · 0928fff · 0928fff
1 parent 1b24152
commit 0928fff
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/projects/RabbitMQ.Client/client/impl/MainSession.cs b/projects/RabbitMQ.Client/client/impl/MainSession.cs
@@ -45,7 +45,6 @@ namespace RabbitMQ.Client.Impl
     ///<summary>Small ISession implementation used only for channel 0.</summary>
     internal sealed class MainSession : Session
     {
-        private readonly object _closingLock = new object();
         private volatile bool _closeServerInitiated;
         private volatile bool _closing;
 
@@ -94,7 +93,7 @@ public void SetSessionClosing(bool closeServerInitiated)
         {
             if (!_closing)
             {
-                lock (_closingLock)
+                lock (this)
                 {
                     if (!_closing)
                     {