From a436cb1f477a6532e1608ef376d7d8877a207705 Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Tue, 3 Mar 2009 23:32:09 +0000
Subject: reset byte credit after flushing when not prefetching, this is a
 follow up fix for QPID-1642/QPID-1643

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@749842 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/qpid/client/BasicMessageConsumer_0_10.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'qpid/java/client/src')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index a2b233b063..8b17dcf91f 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -386,13 +386,13 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<UnprocessedM
         if (o == null && _0_10session.isStarted())
         {
             _0_10session.getQpidSession().messageFlush
-                (getConsumerTagString(), Option.UNRELIABLE);
+                (getConsumerTagString(), Option.UNRELIABLE, Option.SYNC);
             _0_10session.getQpidSession().sync();
+            _0_10session.getQpidSession().messageFlow
+                (getConsumerTagString(), MessageCreditUnit.BYTE,
+                 0xFFFFFFFF, Option.UNRELIABLE);
             if (getSession().prefetch())
             {
-                _0_10session.getQpidSession().messageFlow
-                    (getConsumerTagString(), MessageCreditUnit.BYTE,
-                     0xFFFFFFFF, Option.UNRELIABLE);
                 _0_10session.getQpidSession().messageFlow
                     (getConsumerTagString(), MessageCreditUnit.MESSAGE,
                      _0_10session.getAMQConnection().getMaxPrefetch(),
-- 
cgit v1.2.1