commit b90d0f080316646fc3145ab08e48cc7064b44b4e
author Michael André Pearce <michaelpearce@apache.org> Mon Aug 12 14:09:35 2019 +0100
committer GitHub <noreply@github.com> Mon Aug 12 14:09:35 2019 +0100
tree 550659b10866ea6bf294c20443bdf7442fe65d93
parent 1495a1d46563e5994f270bbadbdb45715228ce66
parent 3af078132e93385c04c6ddfd034b29d7a640f18b

Merge pull request #16 from Havret/AMQNET-597

AMQNET-597: Remotely closed session is not removed from AmqpConnection

src/NMS.AMQP/Provider/Amqp/AmqpSession.cs

diff --git a/src/NMS.AMQP/Provider/Amqp/AmqpSession.cs b/src/NMS.AMQP/Provider/Amqp/AmqpSession.cs
index 7862e5b..4f8c9e5 100644
--- a/src/NMS.AMQP/Provider/Amqp/AmqpSession.cs
+++ b/src/NMS.AMQP/Provider/Amqp/AmqpSession.cs
@@ -63,7 +63,10 @@
                 });
             underlyingSession.AddClosedCallback((sender, error) =>
             {
-                tcs.TrySetException(ExceptionSupport.GetException(error));
+                if (!tcs.TrySetException(ExceptionSupport.GetException(error)))
+                {
+                    Connection.RemoveSession(sessionInfo.Id);
+                }
             });
             return tcs.Task;
         }
@@ -123,7 +126,7 @@
         {
             consumers.TryRemove(consumerId, out _);
         }
-        
+
         public void RemoveProducer(Id producerId)
         {
             producers.TryRemove(producerId, out _);