Author: kwall
Date: Tue Nov 17 16:07:45 2015
New Revision: 1714817
URL: http://svn.apache.org/viewvc?rev=1714817&view=rev
Log:
QPID-6844 : Ensure that the AMQP 1.0 consumer target restores credit (rather
than takes more) on the queue delivery path in the case where a planned
delivery cannot proceed.
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.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/ConsumerTarget_1_0.java?rev=1714817&r1=1714816&r2=1714817&view=diff
==============================================================================
---
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
(original)
+++
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
Tue Nov 17 16:07:45 2015
@@ -316,7 +316,7 @@ class ConsumerTarget_1_0 extends Abstrac
synchronized (_link.getLock())
{
final SendingLinkEndpoint endpoint = _link.getEndpoint();
-
endpoint.setLinkCredit(endpoint.getLinkCredit().subtract(UnsignedInteger.ONE));
+
endpoint.setLinkCredit(endpoint.getLinkCredit().add(UnsignedInteger.ONE));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
