You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2009/08/27 17:20:24 UTC
svn commit: r808454 -
/qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
Author: rgodfrey
Date: Thu Aug 27 15:20:23 2009
New Revision: 808454
URL: http://svn.apache.org/viewvc?rev=808454&view=rev
Log:
credit mode fix
Modified:
qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
Modified: qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java
URL: http://svn.apache.org/viewvc/qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java?rev=808454&r1=808453&r2=808454&view=diff
==============================================================================
--- qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java (original)
+++ qpid/branches/java-broker-0-10/qpid/java/broker/src/main/java/org/apache/qpid/server/flow/CreditCreditManager.java Thu Aug 27 15:20:23 2009
@@ -68,9 +68,9 @@
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 void clearCredit()
{
- //To change body of implemented methods use File | Settings | File Templates.
+ _bytesCredit = 0l;
+ _messageCredit = 0l;
+ setSuspended(true);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org