Call Stop() on the transport layer before disposing of it to ensure that the ResponseCorrelator (and other transports) are properly cleaned up.
Fixes https://issues.apache.org/jira/browse/AMQNET-395
diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs
index 5284f86..c438f60 100755
--- a/src/main/csharp/Connection.cs
+++ b/src/main/csharp/Connection.cs
@@ -586,6 +586,7 @@
executor.Shutdown();
Tracer.DebugFormat("Connection[{0}]: Disposing of the Transport.", this.ConnectionId);
+ transport.Stop();
transport.Dispose();
}
catch(Exception ex)
