activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: StoreDurableSubscriberCursor don't set its inner cursors' maxProducersToAudit correctly #57 - patch applied with thanks
Date Mon, 26 Jan 2015 21:29:03 GMT
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 <gary.tully@gmail.com>
Authored: Mon Jan 26 21:28:35 2015 +0000
Committer: gtully <gary.tully@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);
         }
     }
 


Mime
View raw message