You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2016/11/18 15:35:48 UTC
svn commit: r1770401 -
/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java
Author: lquack
Date: Fri Nov 18 15:35:48 2016
New Revision: 1770401
URL: http://svn.apache.org/viewvc?rev=1770401&view=rev
Log:
QPID-7529: [Java Broker] fix FlowControl on AMQP 1.0
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java
Modified: qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java?rev=1770401&r1=1770400&r2=1770401&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/LinkEndpoint.java Fri Nov 18 15:35:48 2016
@@ -457,13 +457,13 @@ public abstract class LinkEndpoint<T ext
flow.setEcho(echo);
if(_stopped)
{
- flow.setLinkCredit(_linkCredit);
- _lastSentCreditLimit = _linkCredit.add(_deliveryCount);
+ flow.setLinkCredit(UnsignedInteger.ZERO);
+ _lastSentCreditLimit = _deliveryCount;
}
else
{
- flow.setLinkCredit(UnsignedInteger.ZERO);
- _lastSentCreditLimit = _deliveryCount;
+ flow.setLinkCredit(_linkCredit);
+ _lastSentCreditLimit = _linkCredit.add(_deliveryCount);
}
flow.setAvailable(_available);
flow.setDrain(_drain);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org