https://issues.apache.org/jira/browse/AMQNET-484
Eagerly release consumers from transacted sessions if they don't have any pending acks to deliver so their prefetched messages are returned for dispatch right away.
Fixes [AMQNET-AMQNET-484]. (See https://issues.apache.org/jira/browse/AMQNET-AMQNET-484)
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();
}
