credit mode fix

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-0-10@808454 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 3 deletions

diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
index 40ee92efea..b47f986155 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
@@ -68,9 +68,9 @@ public class CreditCreditManager extends AbstractFlowCreditManager implements Fl
 
     public synchronized void restoreCredit(final long messageCredit, final long bytesCredit)
     {
-        _bytesCredit = 0l;
+        /*_bytesCredit = 0l;
         _messageCredit = 0l;
-        setSuspended(true);
+        setSuspended(true);*/
     }
 
     
@@ -106,7 +106,9 @@ public class CreditCreditManager extends AbstractFlowCreditManager implements Fl
 
     public void clearCredit()
     {
-        //To change body of implemented methods use File | Settings | File Templates.
+        _bytesCredit = 0l;
+        _messageCredit = 0l;
+        setSuspended(true);
     }