You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/10/18 13:02:11 UTC
svn commit: r585927 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Author: arnaudsimon
Date: Thu Oct 18 04:02:11 2007
New Revision: 585927
URL: http://svn.apache.org/viewvc?rev=585927&view=rev
Log:
Changed logic for reseting credit
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=585927&r1=585926&r2=585927&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 18 04:02:11 2007
@@ -267,7 +267,6 @@
_logger.debug("filterMessage - trying to ack message");
}
acknowledgeMessage(message);
- requestCreditIfCreditMode();
}
else if (!messageOk)
{
@@ -276,7 +275,6 @@
_logger.debug("Message not OK, releasing");
}
releaseMessage(message);
- requestCreditIfCreditMode();
}
// now we need to acquire this message if needed
// this is the case of queue with a message selector set
@@ -287,6 +285,10 @@
_logger.debug("filterMessage - trying to acquire message");
}
messageOk = acquireMessage(message);
+ }
+ if( ! messageOk )
+ {
+ requestCreditIfCreditMode();
}
return messageOk;
}