Arnaud, I am not sure if this line is needed. Each time we unsuspend a channel or each time the flow mode is changed we set this. _0_10session.getQpidSession().messageFlow(getConsumerTag().toString(), Session.MESSAGE_FLOW_UNIT_BYTE, 0xFFFFFFFF); Was this in response to a particular issue?
Regards, Rajith On 10/11/07, [EMAIL PROTECTED] <[EMAIL PROTECTED]> wrote: > > Author: arnaudsimon > Date: Thu Oct 11 05:01:50 2007 > New Revision: 583785 > > URL: http://svn.apache.org/viewvc?rev=583785&view=rev > Log: > added byte credits when no message is reeived > > 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=583785&r1=583784&r2=583785&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 > Thu Oct 11 05:01:50 2007 > @@ -376,6 +376,7 @@ > // checking if one is inflight > > _0_10session.getQpidSession().messageFlush(getConsumerTag().toString()); > _0_10session.getQpidSession().sync(); > > + > _0_10session.getQpidSession().messageFlow(getConsumerTag().toString(), > Session.MESSAGE_FLOW_UNIT_BYTE, 0xFFFFFFFF); > o = _synchronousQueue.poll(); > } > } > > >
