activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r701072 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
Date Thu, 02 Oct 2008 10:46:15 GMT
Author: gtully
Date: Thu Oct  2 03:46:15 2008
New Revision: 701072

URL: http://svn.apache.org/viewvc?rev=701072&view=rev
Log:
fix AMQ-1962, reset or cursor as a result of empty subscription list was incorrectly setting
store size to 0

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java?rev=701072&r1=701071&r2=701072&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java
Thu Oct  2 03:46:15 2008
@@ -194,7 +194,7 @@
         batchList.clear();
         batchResetNeeded = true;
         this.cacheEnabled=false;
-        size=0;
+        size = getStoreSize();
     }
     
     protected final synchronized void fillBatch() {



Mime
View raw message