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 <[email protected]> Authored: Fri Aug 19 11:48:42 2016 +0100 Committer: gtully <[email protected]> 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;
