Repository: qpid-broker-j Updated Branches: refs/heads/6.1.x eeb0e05bd -> fb6e31c6c
QPID-7505: Sync session after sending flow command to restore credits after credits reset in result of execution of message.flush as part of BaseicMessageConsumer_0_10#receive() (cherry picked from commit f903afcbd534cefb23df21a41224e0774d61adc3) Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/fb6e31c6 Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/fb6e31c6 Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/fb6e31c6 Branch: refs/heads/6.1.x Commit: fb6e31c6c260f747416baaaaa4abf98a8b071c11 Parents: eeb0e05 Author: Alex Rudyy <[email protected]> Authored: Thu Nov 10 11:22:54 2016 +0000 Committer: Alex Rudyy <[email protected]> Committed: Fri Apr 28 09:18:24 2017 +0100 ---------------------------------------------------------------------- .../java/org/apache/qpid/client/BasicMessageConsumer_0_10.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/fb6e31c6/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java index f9b9592..a7280b0 100644 --- a/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java +++ b/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java @@ -401,7 +401,6 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM _0_10session.getQpidSession().messageFlush (getConsumerTagString(), Option.UNRELIABLE, Option.SYNC); - _0_10session.getQpidSession().sync(); _0_10session.getQpidSession().messageFlow (getConsumerTagString(), MessageCreditUnit.BYTE, 0xFFFFFFFF, Option.UNRELIABLE); @@ -414,6 +413,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM _capacity, Option.UNRELIABLE); } + _0_10session.getQpidSession().sync(); _0_10session.syncDispatchQueue(false); o = super.getMessageFromQueue(-1); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
