helix-commits mailing list archives

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


Mime
View raw message