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/06/26 20:12:56 UTC
git commit: [HELIX-463] Create useful message queue length jmx,
update count
Repository: helix
Updated Branches:
refs/heads/helix-0.6.x 6a8b711f8 -> 3cf3de33f
[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/3cf3de33
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/3cf3de33
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/3cf3de33
Branch: refs/heads/helix-0.6.x
Commit: 3cf3de33f556c406e5da9d38de3f66fcf5be5fe7
Parents: 6a8b711
Author: Kanak Biscuitwala <ka...@apache.org>
Authored: Thu Jun 26 11:12:49 2014 -0700
Committer: Kanak Biscuitwala <ka...@apache.org>
Committed: Thu Jun 26 11:12:49 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/3cf3de33/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 c6055c7..fec242f 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
@@ -516,6 +516,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);