commit 625b6344b898c4e6d329e0784db9be607ae391f3
author Timothy A. Bish <tabish@apache.org> Wed Jul 16 20:14:50 2014 +0000
committer Timothy A. Bish <tabish@apache.org> Wed Jul 16 20:14:50 2014 +0000
tree 057fadfb173e053b1a18b30990c8e73e63cb37f0
parent 0f5eb15a91dccd4f53cffc5a86403fb285a8d3b4

https://issues.apache.org/jira/browse/AMQNET-483

Ensure the the ConsumerCloseSynchronization doesn't try to close the same consumer more than once.
Fixes [AMQNET-AMQNET-483]. (See https://issues.apache.org/jira/browse/AMQNET-AMQNET-483)

src/main/csharp/MessageConsumer.cs

diff --git a/src/main/csharp/MessageConsumer.cs b/src/main/csharp/MessageConsumer.cs
index d12b9d9..813aaf6 100755
--- a/src/main/csharp/MessageConsumer.cs
+++ b/src/main/csharp/MessageConsumer.cs
@@ -1810,16 +1810,22 @@
 
 			public void AfterCommit()
 			{
-                Tracer.DebugFormat("ConsumerCloseSynchronization - AfterCommit Called for Consumer {0}.",
-                                   this.consumer.ConsumerId);
-                this.consumer.DoClose();
+                if (!this.consumer.Closed) 
+                {
+                    Tracer.DebugFormat("ConsumerCloseSynchronization - AfterCommit Called for Consumer {0}.",
+                                       this.consumer.ConsumerId);
+                    this.consumer.DoClose();
+                }
 			}
 
 			public void AfterRollback()
 			{
-                Tracer.DebugFormat("ConsumerCloseSynchronization - AfterRollback Called for Consumer {0}.",
-                                   this.consumer.ConsumerId);
-                this.consumer.DoClose();
+                if (!this.consumer.Closed) 
+                {
+                    Tracer.DebugFormat("ConsumerCloseSynchronization - AfterRollback Called for Consumer {0}.",
+                                       this.consumer.ConsumerId);
+                    this.consumer.DoClose();
+                }
 			}
 		}