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: [email protected]
For additional commands, e-mail: [email protected]
