You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by dk...@apache.org on 2015/08/04 17:59:21 UTC
[02/10] activemq git commit:
https://issues.apache.org/jira/browse/AMQ-5742 - fix and intermittent failure
of DemandForwardingBridgeTest is sorted
https://issues.apache.org/jira/browse/AMQ-5742 - fix and intermittent failure of DemandForwardingBridgeTest is sorted
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2ad1f1ea
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2ad1f1ea
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2ad1f1ea
Branch: refs/heads/activemq-5.11.x
Commit: 2ad1f1eaa97e157c7d512eaee0018592d2074a79
Parents: 8ff47d6
Author: gtully <ga...@gmail.com>
Authored: Thu Apr 23 14:32:40 2015 +0100
Committer: Daniel Kulp <dk...@apache.org>
Committed: Tue Aug 4 08:44:16 2015 -0400
----------------------------------------------------------------------
.../org/apache/activemq/broker/region/PrefetchSubscription.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/2ad1f1ea/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
index b101d72..1e01f39 100755
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
@@ -625,7 +625,6 @@ public abstract class PrefetchSubscription extends AbstractSubscription {
}
}
rc.addAll(references);
- destination.getDestinationStatistics().getDispatched().subtract(references.size());
destination.getDestinationStatistics().getInflight().subtract(references.size());
dispatched.removeAll(references);
}