commit b62a478b23edf66ee7741d5163f09e94fcde502d
author Timothy A. Bish <tabish@apache.org> Tue Aug 12 15:58:41 2014 +0000
committer Timothy A. Bish <tabish@apache.org> Tue Aug 12 15:58:41 2014 +0000
tree 7d84ceb6bf6bb7fc37c0d1b9781963fba337768d
parent fe211f0038c19166bd0344fdc8bee2b17f1c1990

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

src/main/csharp/MessageConsumer.cs

diff --git a/src/main/csharp/MessageConsumer.cs b/src/main/csharp/MessageConsumer.cs
index d4db586..691f187 100644
--- a/src/main/csharp/MessageConsumer.cs
+++ b/src/main/csharp/MessageConsumer.cs
@@ -116,6 +116,7 @@
             {
                 try
                 {
+                    qpidReceiver.Close();
                     qpidReceiver.Dispose();
                     qpidReceiver = null;
                 }
@@ -213,6 +214,7 @@
         public void Close()
         {
             StopAsyncDelivery();
+            Stop();
         }
 
         protected virtual void StopAsyncDelivery()

src/main/csharp/MessageProducer.cs

diff --git a/src/main/csharp/MessageProducer.cs b/src/main/csharp/MessageProducer.cs
index 2a1f2cb..af31358 100644
--- a/src/main/csharp/MessageProducer.cs
+++ b/src/main/csharp/MessageProducer.cs
@@ -103,6 +103,7 @@
                 try
                 {
                     Tracer.DebugFormat("Stop  Producer Id = " + ProducerId);
+                    qpidSender.Close();
                     qpidSender.Dispose();
                     qpidSender = null;
                 }
@@ -168,6 +169,7 @@
 
         public void Close()
         {
+            Stop();
         }
 
         public void Dispose()