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

StoreDurableSubscriberCursor don't set its inner cursors' maxProducersToAudit correctly #57 - patch applied with thanks

This commit is contained in:
gtully 2015-01-26 21:28:35 +00:00
parent 60c9d03e1d
commit 6c5dd2543e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -337,7 +337,7 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
public void setMaxProducersToAudit(int maxProducersToAudit) {
super.setMaxProducersToAudit(maxProducersToAudit);
for (PendingMessageCursor cursor : storePrefetches) {
cursor.setMaxAuditDepth(maxAuditDepth);
cursor.setMaxProducersToAudit(maxProducersToAudit);
}
}