activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r492993 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java
Date Fri, 05 Jan 2007 11:47:49 GMT
Author: rajdavies
Date: Fri Jan  5 03:47:49 2007
New Revision: 492993

URL: http://svn.apache.org/viewvc?view=rev&rev=492993
Log:
optimization for large number of queue consumers

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java?view=diff&rev=492993&r1=492992&r2=492993
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java
Fri Jan  5 03:47:49 2007
@@ -110,7 +110,7 @@
         int rc = --referenceCount;
         if( persistent && rc == 0 && message!=null) {
             message.decrementReferenceCount();
-            message=null;
+            //message=null;
         }
         return rc;
     }



Mime
View raw message