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;