qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ritch...@apache.org
Subject svn commit: r761674 - /qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
Date Fri, 03 Apr 2009 13:46:43 GMT
Author: ritchiem
Date: Fri Apr  3 13:46:43 2009
New Revision: 761674

URL: http://svn.apache.org/viewvc?rev=761674&view=rev
Log:
QPID-1784 : Fixed compile error

Modified:
    qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java

Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java?rev=761674&r1=761673&r2=761674&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
(original)
+++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/FlowableBaseQueueEntryList.java
Fri Apr  3 13:46:43 2009
@@ -428,7 +428,7 @@
         }
 
         //If we have become flowed or have more capacity since we stopped then schedule the
thread to run again.
-        if (!finshedInhaling _flowed.get() && _atomicQueueInMemory.get() < _memoryUsageMaximum)
+        if (!finshedInhaling && _flowed.get() && _atomicQueueInMemory.get()
< _memoryUsageMaximum)
         {
             if (_log.isInfoEnabled())
             {



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message