summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2007-10-19 15:14:06 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2007-10-19 15:14:06 +0000
commit7b22f028d252fab44a58f72014eb3896031ccecc (patch)
tree1904f4d64c64e33324658349e5f4e593d4dd3810
parent0d1241b9ff64467c23a5146e9614202026536adc (diff)
downloadqpid-python-7b22f028d252fab44a58f72014eb3896031ccecc.tar.gz
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
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java5
1 files changed, 3 insertions, 2 deletions
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