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/05/23 15:03:09 UTC

svn commit: r659527 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java

Author: rajdavies
Date: Fri May 23 06:03:08 2008
New Revision: 659527

URL: http://svn.apache.org/viewvc?rev=659527&view=rev
Log:
set the memoryUsageHighWaterMark to 70 by default

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

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java?rev=659527&r1=659526&r2=659527&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java Fri May 23 06:03:08 2008
@@ -19,12 +19,10 @@
 import java.util.Collections;
 import java.util.LinkedList;
 import java.util.List;
-
 import org.apache.activemq.ActiveMQMessageAudit;
 import org.apache.activemq.broker.ConnectionContext;
 import org.apache.activemq.broker.region.Destination;
 import org.apache.activemq.broker.region.MessageReference;
-import org.apache.activemq.broker.region.QueueMessageReference;
 import org.apache.activemq.command.MessageId;
 import org.apache.activemq.usage.SystemUsage;
 
@@ -35,7 +33,7 @@
  * @version $Revision$
  */
 public class AbstractPendingMessageCursor implements PendingMessageCursor {
-    protected int memoryUsageHighWaterMark = 90;
+    protected int memoryUsageHighWaterMark = 70;
     protected int maxBatchSize = 100;
     protected SystemUsage systemUsage;
     protected int maxProducersToAudit=1024;