You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/04/28 08:19:46 UTC
qpid-broker-j git commit: 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()
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 <or...@apache.org>
Authored: Thu Nov 10 11:22:54 2016 +0000
Committer: Alex Rudyy <or...@apache.org>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org