activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: fix up cancelledTaskModMetric reporting in kahadb
Date Fri, 19 Aug 2016 10:48:59 GMT
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 <gary.tully@gmail.com>
Authored: Fri Aug 19 11:48:42 2016 +0100
Committer: gtully <gary.tully@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;


Mime
View raw message