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

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

Author: ataylor
Date: 2008-10-02 04:02:47 -0400 (Thu, 02 Oct 2008)
New Revision: 5059

Modified:
   trunk/src/main/org/jboss/messaging/core/postoffice/impl/FlowControllerImpl.java
Log:
https://jira.jboss.org/jira/browse/JBMESSAGING-1405 - flow control fix

Modified: trunk/src/main/org/jboss/messaging/core/postoffice/impl/FlowControllerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/postoffice/impl/FlowControllerImpl.java	2008-10-01 18:42:02 UTC (rev 5058)
+++ trunk/src/main/org/jboss/messaging/core/postoffice/impl/FlowControllerImpl.java	2008-10-02 08:02:47 UTC (rev 5059)
@@ -22,14 +22,14 @@
 
 package org.jboss.messaging.core.postoffice.impl;
 
-import java.util.concurrent.ConcurrentLinkedQueue;
-
 import org.jboss.messaging.core.logging.Logger;
 import org.jboss.messaging.core.postoffice.FlowController;
 import org.jboss.messaging.core.postoffice.PostOffice;
 import org.jboss.messaging.core.server.ServerProducer;
 import org.jboss.messaging.util.SimpleString;
 
+import java.util.concurrent.ConcurrentLinkedQueue;
+
 /**
  * 
  * A FlowControllerImpl
@@ -118,7 +118,7 @@
 		{
 		   int creditsToTake = Math.min(credits, creditPot);
 		   
-			creditPot -= creditsToTake;
+			//creditPot -= creditsToTake;
 			
 			producer.sendCredits(creditsToTake);
 		}