From 84e591ba778d7050cef4f60a71dd3d56d4b9155c Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 27 Aug 2009 15:20:23 +0000 Subject: credit mode fix git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-0-10@808454 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/flow/CreditCreditManager.java | 8 +++++--- 1 file 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); } -- cgit v1.2.1