svn commit: r585927 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java

[arnaudsimon]

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;
     }