From 7b22f028d252fab44a58f72014eb3896031ccecc Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Fri, 19 Oct 2007 15:14:06 +0000
Subject: Fix for the credit issue when we release messages that fails the
 selector test

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586496 13f79535-47bb-0310-9956-ffa450edef68
---
 .../main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'java')

diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
index 024558eaaf..fbfc9d80ec 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
@@ -104,7 +104,7 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
             {
                 _preAcquire = false;
             }
-        }                
+        }
     }
 
     // ----- Interface org.apache.qpidity.client.util.MessageListener
@@ -327,12 +327,13 @@ public class BasicMessageConsumer_0_10 extends BasicMessageConsumer<Struct[], By
                   int oldval = _messageCounter.intValue();
                 _0_10session.getQpidSession().messageFlow(getConsumerTag().toString(),
                     org.apache.qpidity.nclient.Session.MESSAGE_FLOW_UNIT_MESSAGE,1);
+                _0_10session.getQpidSession().messageFlow(getConsumerTag().toString(),Session.MESSAGE_FLOW_UNIT_BYTE, 0xFFFFFFFF);
                 _0_10session.getQpidSession().messageFlush(getConsumerTag().toString());
                 _0_10session.getQpidSession().sync();
                 _0_10session.getQpidSession().messageFlow(getConsumerTag().toString(),Session.MESSAGE_FLOW_UNIT_BYTE, 0xFFFFFFFF);
                 if( _messageCounter.intValue() <= oldval )
                 {
-                    // we haven't received a message so tell the receiver to return null                     
+                    // we haven't received a message so tell the receiver to return null
                     _synchronousQueue.add(new NullTocken());
                 }
                 else
-- 
cgit v1.2.1