Author: rhs
Date: Tue Mar 3 23:32:09 2009
New Revision: 749842
URL: http://svn.apache.org/viewvc?rev=749842&view=rev
Log:
reset byte credit after flushing when not prefetching, this is a follow up fix
for QPID-1642/QPID-1643
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=749842&r1=749841&r2=749842&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Tue Mar 3 23:32:09 2009
@@ -386,14 +386,14 @@
if (o == null && _0_10session.isStarted())
{
_0_10session.getQpidSession().messageFlush
- (getConsumerTagString(), Option.UNRELIABLE);
+ (getConsumerTagString(), Option.UNRELIABLE, Option.SYNC);
_0_10session.getQpidSession().sync();
+ _0_10session.getQpidSession().messageFlow
+ (getConsumerTagString(), MessageCreditUnit.BYTE,
+ 0xFFFFFFFF, Option.UNRELIABLE);
if (getSession().prefetch())
{
_0_10session.getQpidSession().messageFlow
- (getConsumerTagString(), MessageCreditUnit.BYTE,
- 0xFFFFFFFF, Option.UNRELIABLE);
- _0_10session.getQpidSession().messageFlow
(getConsumerTagString(), MessageCreditUnit.MESSAGE,
_0_10session.getAMQConnection().getMaxPrefetch(),
Option.UNRELIABLE);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
