Author: tabish Date: Tue Aug 12 15:58:41 2014 New Revision: 1617515 URL: http://svn.apache.org/r1617515 Log: https://issues.apache.org/jira/browse/AMQNET-454
apply: https://issues.apache.org/jira/secure/attachment/12661228/Apache.NMS.AMQP-28-close-qpid-sender-receiver.patch Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs?rev=1617515&r1=1617514&r2=1617515&view=diff ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs (original) +++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageConsumer.cs Tue Aug 12 15:58:41 2014 @@ -116,6 +116,7 @@ namespace Apache.NMS.Amqp { try { + qpidReceiver.Close(); qpidReceiver.Dispose(); qpidReceiver = null; } @@ -213,6 +214,7 @@ namespace Apache.NMS.Amqp public void Close() { StopAsyncDelivery(); + Stop(); } protected virtual void StopAsyncDelivery() Modified: activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs?rev=1617515&r1=1617514&r2=1617515&view=diff ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs (original) +++ activemq/activemq-dotnet/Apache.NMS.AMQP/trunk/src/main/csharp/MessageProducer.cs Tue Aug 12 15:58:41 2014 @@ -103,6 +103,7 @@ namespace Apache.NMS.Amqp try { Tracer.DebugFormat("Stop Producer Id = " + ProducerId); + qpidSender.Close(); qpidSender.Dispose(); qpidSender = null; } @@ -168,6 +169,7 @@ namespace Apache.NMS.Amqp public void Close() { + Stop(); } public void Dispose()
