Author: rajith
Date: Fri Oct 19 08:14:06 2007
New Revision: 586496
URL: http://svn.apache.org/viewvc?rev=586496&view=rev
Log:
Fix for the credit issue when we release messages that fails the selector test
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=586496&r1=586495&r2=586496&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Fri Oct 19 08:14:06 2007
@@ -104,7 +104,7 @@
{
_preAcquire = false;
}
- }
+ }
}
// ----- Interface org.apache.qpidity.client.util.MessageListener
@@ -327,12 +327,13 @@
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
