Author: rgodfrey
Date: Wed Jun 27 19:28:03 2012
New Revision: 1354682
URL: http://svn.apache.org/viewvc?rev=1354682&view=rev
Log:
NO-JIRA : [Proton-j] fix partial drain
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportReceiver.java
Modified:
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportReceiver.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportReceiver.java?rev=1354682&r1=1354681&r2=1354682&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportReceiver.java
(original)
+++
qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/engine/impl/TransportReceiver.java
Wed Jun 27 19:28:03 2012
@@ -44,7 +44,7 @@ class TransportReceiver extends Transpor
super.handleFlow(flow);
if(getRemoteDeliveryCount().compareTo(getDeliveryCount())>=0)
{
- getLink().setCredit(getRemoteLinkCredit().intValue());
+ getLink().setCredit(getLink().getQueued());
setLinkCredit(getRemoteLinkCredit());
setDeliveryCount(getRemoteDeliveryCount());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
