[jboss-cvs] JBoss Messaging SVN: r3214 - trunk/src/main/org/jboss/messaging/core/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-10-19 18:59:29 -0400 (Fri, 19 Oct 2007)
New Revision: 3214

Modified:
   trunk/src/main/org/jboss/messaging/core/impl/MessagingQueue.java
Log:
Adjustment to message pulling


Modified: trunk/src/main/org/jboss/messaging/core/impl/MessagingQueue.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/impl/MessagingQueue.java	2007-10-19 21:41:35 UTC (rev 3213)
+++ trunk/src/main/org/jboss/messaging/core/impl/MessagingQueue.java	2007-10-19 22:59:29 UTC (rev 3214)
@@ -512,7 +512,8 @@
 		
 		if (trace) { log.trace(this + " deliverInternal"); }
 		
-		if (handleFlowControlForConsumers && getReceiversReady() && localDistributor.getNumberOfReceivers() > 0)
+		if (handleFlowControlForConsumers && getReceiversReady() &&
+			 localDistributor.getNumberOfReceivers() > 0 && messageRefs.isEmpty())
 		{
 			if (trace) { log.trace("Informing suckers"); }
 			//The receivers are still ready for more messages but there is nothing left in the local queue