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 2016/08/19 10:48:59 UTC
activemq git commit: fix up cancelledTaskModMetric reporting in kahadb
Repository: activemq
Updated Branches:
refs/heads/master e52a05276 -> b37b9eb5a
fix up cancelledTaskModMetric reporting in kahadb
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b37b9eb5
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b37b9eb5
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b37b9eb5
Branch: refs/heads/master
Commit: b37b9eb5afed8261f657b5847e8691b3804d0f60
Parents: e52a052
Author: gtully <ga...@gmail.com>
Authored: Fri Aug 19 11:48:42 2016 +0100
Committer: gtully <ga...@gmail.com>
Committed: Fri Aug 19 11:48:42 2016 +0100
----------------------------------------------------------------------
.../main/java/org/apache/activemq/store/kahadb/KahaDBStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/b37b9eb5/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
----------------------------------------------------------------------
diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
index 0d20b78..f2ba0de 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
@@ -1413,7 +1413,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
this.store.addMessage(context, message);
removeQueueTask(this.store, this.message.getMessageId());
this.future.complete();
- } else if (cancelledTaskModMetric > 0 && this.store.canceledTasks++ % cancelledTaskModMetric == 0) {
+ } else if (cancelledTaskModMetric > 0 && (++this.store.canceledTasks) % cancelledTaskModMetric == 0) {
System.err.println(this.store.dest.getName() + " cancelled: "
+ (this.store.canceledTasks / this.store.doneTasks) * 100);
this.store.canceledTasks = this.store.doneTasks = 0;