diff --git a/src/main/csharp/MessageConsumer.cs b/src/main/csharp/MessageConsumer.cs
index 813aaf6..3c02041 100755
--- a/src/main/csharp/MessageConsumer.cs
+++ b/src/main/csharp/MessageConsumer.cs
@@ -434,7 +434,7 @@
 		{
 			if(!this.unconsumedMessages.Closed)
 			{
-				if(this.session.IsTransacted && this.session.TransactionContext.InTransaction)
+				if(this.dispatchedMessages.Count != 0 && this.session.IsTransacted && this.session.TransactionContext.InTransaction)
 				{
                     Tracer.DebugFormat("Consumer {0} Registering new ConsumerCloseSynchronization",
                                        this.info.ConsumerId);
@@ -442,7 +442,7 @@
 				}
 				else
 				{
-                    Tracer.DebugFormat("Consumer {0} No Active TX closing normally.",
+                    Tracer.DebugFormat("Consumer {0} No Active TX or pending acks, closing normally.",
                                        this.info.ConsumerId);
                     this.DoClose();
 				}