You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2008/01/25 19:25:05 UTC
svn commit: r615297 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
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;
}
}