Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

set the memoryUsageHighWaterMark to 70 by default 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@659527 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-05-23 13:03:08 +00:00
parent 87403404d2
commit 1f9e67f2b7
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
View File

@ -19,12 +19,10 @@ package org.apache.activemq.broker.region.cursors;
import java.util.Collections; import java.util.Collections;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import org.apache.activemq.ActiveMQMessageAudit; import org.apache.activemq.ActiveMQMessageAudit;
import org.apache.activemq.broker.ConnectionContext; import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.broker.region.Destination; import org.apache.activemq.broker.region.Destination;
import org.apache.activemq.broker.region.MessageReference; import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.broker.region.QueueMessageReference;
import org.apache.activemq.command.MessageId; import org.apache.activemq.command.MessageId;
import org.apache.activemq.usage.SystemUsage; import org.apache.activemq.usage.SystemUsage;
@ -35,7 +33,7 @@ import org.apache.activemq.usage.SystemUsage;
* @version $Revision$ * @version $Revision$
*/ */
public class AbstractPendingMessageCursor implements PendingMessageCursor { public class AbstractPendingMessageCursor implements PendingMessageCursor {
protected int memoryUsageHighWaterMark = 90; protected int memoryUsageHighWaterMark = 70;
protected int maxBatchSize = 100; protected int maxBatchSize = 100;
protected SystemUsage systemUsage; protected SystemUsage systemUsage;
protected int maxProducersToAudit=1024; protected int maxProducersToAudit=1024;