helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ka...@apache.org
Subject [13/17] git commit: [HELIX-463] Create useful message queue length jmx, update count
Date Fri, 11 Jul 2014 19:58:08 GMT
[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 <kanak@apache.org>
Authored: Thu Jun 26 11:12:49 2014 -0700
Committer: Kanak Biscuitwala <kanak@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);
 


Mime
View raw message