qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r585927 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
Date Thu, 18 Oct 2007 11:02:11 GMT
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;
     }



Mime
View raw message