Arnaud, Figured it out, the flush will actually exhaust all credit, so we need to add byte credits again.
Regards, Rajith On 10/11/07, Rajith Attapattu <[EMAIL PROTECTED]> wrote: > > 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(); > > } > > } > > > > > > >
