Repository: qpid-proton Updated Branches: refs/heads/0.11.x 0af481e09 -> 3a8782b98
PROTON-1077: adjust the receivers transport credit state by the same delta as the link credit state when deliveryCount advances to keep them in sync (cherry picked from commit a8d87bb3c6d54458d7041d38374feb8b7cf30667) Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/3a8782b9 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/3a8782b9 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/3a8782b9 Branch: refs/heads/0.11.x Commit: 3a8782b9871fa35db0c69c994c4c4667251242b0 Parents: 0af481e Author: Robert Gemmell <[email protected]> Authored: Tue Dec 15 13:00:41 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Dec 15 15:40:15 2015 +0000 ---------------------------------------------------------------------- .../java/org/apache/qpid/proton/engine/impl/TransportReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/3a8782b9/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java ---------------------------------------------------------------------- diff --git a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java index fcaec28..29d97c4 100644 --- a/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java +++ b/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/TransportReceiver.java @@ -48,7 +48,7 @@ class TransportReceiver extends TransportLink<ReceiverImpl> if(delta > 0) { getLink().addCredit(-delta); - setLinkCredit(getRemoteLinkCredit()); + addCredit(-delta); setDeliveryCount(getRemoteDeliveryCount()); getLink().setDrained(getLink().getDrained() + delta); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
