You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2009/03/04 00:32:10 UTC
svn commit: r749842 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
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:commits-subscribe@qpid.apache.org