activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r615297 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
Date Fri, 25 Jan 2008 18:25:05 GMT
Author: rajdavies
Date: Fri Jan 25 10:25:04 2008
New Revision: 615297

URL: http://svn.apache.org/viewvc?rev=615297&view=rev
Log:
turn cache off by default

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

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java?rev=615297&r1=615296&r2=615297&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
Fri Jan 25 10:25:04 2008
@@ -44,12 +44,11 @@
     private int size;
     private boolean fillBatchDuplicates;
     private boolean cacheEnabled;
+    private boolean useCache =false;
 
     /**
-     * @param topic
-     * @param clientId
-     * @param subscriberName
-     * @throws IOException
+     * Construct it
+     * @param queue
      */
     public QueueStorePrefetch(Queue queue) {
         this.regionDestination = queue;
@@ -60,7 +59,7 @@
     public synchronized void start() throws Exception{
         if (!isStarted()) {
             this.size = getStoreSize();
-            if (this.size==0) {
+            if (this.size==0&&useCache) {
                 cacheEnabled=true;
             }
         }



Mime
View raw message