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

Apply patch from https://issues.apache.org/activemq/browse/AMQ-2002 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@813962 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2009-09-11 18:06:11 +00:00
parent e01acf44ca
commit e7c9d21660
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
View File

@ -66,8 +66,8 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
}else { }else {
this.nonPersistent = new VMPendingMessageCursor(); this.nonPersistent = new VMPendingMessageCursor();
} }
//TODO is this correct? we are ignoring the constructor parameter matchBatchSize
// this.nonPersistent.setMaxBatchSize(getMaxBatchSize()); this.nonPersistent.setMaxBatchSize(maxBatchSize);
this.nonPersistent.setSystemUsage(systemUsage); this.nonPersistent.setSystemUsage(systemUsage);
this.storePrefetches.add(this.nonPersistent); this.storePrefetches.add(this.nonPersistent);
} }
@ -106,6 +106,7 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
tsp.setEnableAudit(isEnableAudit()); tsp.setEnableAudit(isEnableAudit());
tsp.setMaxAuditDepth(getMaxAuditDepth()); tsp.setMaxAuditDepth(getMaxAuditDepth());
tsp.setMaxProducersToAudit(getMaxProducersToAudit()); tsp.setMaxProducersToAudit(getMaxProducersToAudit());
tsp.setMemoryUsageHighWaterMark(getMemoryUsageHighWaterMark());
topics.put(destination, tsp); topics.put(destination, tsp);
storePrefetches.add(tsp); storePrefetches.add(tsp);
if (isStarted()) { if (isStarted()) {
@ -259,6 +260,13 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
} }
} }
public void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) {
super.setMemoryUsageHighWaterMark(memoryUsageHighWaterMark);
for (PendingMessageCursor cursor : storePrefetches) {
cursor.setMemoryUsageHighWaterMark(memoryUsageHighWaterMark);
}
}
public void setMaxProducersToAudit(int maxProducersToAudit) { public void setMaxProducersToAudit(int maxProducersToAudit) {
super.setMaxProducersToAudit(maxProducersToAudit); super.setMaxProducersToAudit(maxProducersToAudit);
for (PendingMessageCursor cursor : storePrefetches) { for (PendingMessageCursor cursor : storePrefetches) {