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
Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/commit/ca08c348 Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/ca08c348 Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/ca08c348 Branch: refs/heads/1.5.x Commit: ca08c348e986b870d69b1a64deb15a3de11f4627 Parents: f9535df Author: Jim Gomes <[email protected]> Authored: Thu Aug 23 23:42:36 2012 +0000 Committer: Jim Gomes <[email protected]> Committed: Thu Aug 23 23:42:36 2012 +0000 ---------------------------------------------------------------------- src/main/csharp/Connection.cs | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/ca08c348/src/main/csharp/Connection.cs ---------------------------------------------------------------------- diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs index 283158d..b62889e 100755 --- a/src/main/csharp/Connection.cs +++ b/src/main/csharp/Connection.cs @@ -443,6 +443,7 @@ namespace Apache.NMS.Stomp } Tracer.Info("Disposing of the Transport."); + transport.Stop(); transport.Dispose(); } catch(Exception ex)
