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
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/a8d87bb3 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/a8d87bb3 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/a8d87bb3 Branch: refs/heads/go1 Commit: a8d87bb3c6d54458d7041d38374feb8b7cf30667 Parents: a4a21be Author: Robert Gemmell <[email protected]> Authored: Tue Dec 15 13:00:41 2015 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Dec 15 15:21:21 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/a8d87bb3/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]
