diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java | 8 |
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); } |