You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by ka...@apache.org on 2014/07/11 21:58:08 UTC
[13/17] git commit: [HELIX-463] Create useful message queue length
jmx, update count
[HELIX-463] Create useful message queue length jmx, update count
Project: http://git-wip-us.apache.org/repos/asf/helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/c24a7301
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/c24a7301
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/c24a7301
Branch: refs/heads/master
Commit: c24a7301297382823f3063660d77e5af31f6f95e
Parents: 2ccaa6b
Author: Kanak Biscuitwala <ka...@apache.org>
Authored: Thu Jun 26 11:12:49 2014 -0700
Committer: Kanak Biscuitwala <ka...@apache.org>
Committed: Fri Jul 11 12:49:51 2014 -0700
----------------------------------------------------------------------
.../org/apache/helix/messaging/handling/HelixTaskExecutor.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/helix/blob/c24a7301/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
index c4d7a67..0ac3b58 100644
--- a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
+++ b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
@@ -518,6 +518,9 @@ public class HelixTaskExecutor implements MessageListener, TaskExecutor {
return;
}
+ // Update message count
+ _messageQueueMonitor.setMessageQueueBacklog(messages.size());
+
// sort message by creation timestamp, so message created earlier is processed first
Collections.sort(messages, Message.CREATE_TIME_COMPARATOR);