You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2015/01/26 22:29:03 UTC
activemq git commit: StoreDurableSubscriberCursor don't set its inner
cursors' maxProducersToAudit correctly #57 - patch applied with thanks
Repository: activemq
Updated Branches:
refs/heads/trunk 60c9d03e1 -> 6c5dd2543
StoreDurableSubscriberCursor don't set its inner cursors' maxProducersToAudit correctly #57 - patch applied with thanks
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6c5dd254
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6c5dd254
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6c5dd254
Branch: refs/heads/trunk
Commit: 6c5dd2543ea4b60d74f209ff39977214b75946ec
Parents: 60c9d03
Author: gtully <ga...@gmail.com>
Authored: Mon Jan 26 21:28:35 2015 +0000
Committer: gtully <ga...@gmail.com>
Committed: Mon Jan 26 21:28:35 2015 +0000
----------------------------------------------------------------------
.../broker/region/cursors/StoreDurableSubscriberCursor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/6c5dd254/activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
----------------------------------------------------------------------
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 1820e7b..32000f5 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 class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
public void setMaxProducersToAudit(int maxProducersToAudit) {
super.setMaxProducersToAudit(maxProducersToAudit);
for (PendingMessageCursor cursor : storePrefetches) {
- cursor.setMaxAuditDepth(maxAuditDepth);
+ cursor.setMaxProducersToAudit(maxProducersToAudit);
}
}