From 34c9858cbb19c99bb3fae9466420d4b30f2b2c0d Mon Sep 17 00:00:00 2001 From: leisore Date: Tue, 20 Jan 2015 19:03:04 +0800 Subject: [PATCH] StoreDurableSubscriberCursor don't set its inner cursors' maxProducersToAudit correctly --- .../broker/region/cursors/StoreDurableSubscriberCursor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java index 1820e7b9395..32000f53a6e 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java @@ -337,7 +337,7 @@ public void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) { public void setMaxProducersToAudit(int maxProducersToAudit) { super.setMaxProducersToAudit(maxProducersToAudit); for (PendingMessageCursor cursor : storePrefetches) { - cursor.setMaxAuditDepth(maxAuditDepth); + cursor.setMaxProducersToAudit(maxProducersToAudit); } }