[rhmessaging-commits] rhmessaging commits: r1347 - mgmt/cumin/python/cumin.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2007-11-20 16:34:39 -0500 (Tue, 20 Nov 2007)
New Revision: 1347

Modified:
   mgmt/cumin/python/cumin/queue.py
Log:
Restores rates to working.



Modified: mgmt/cumin/python/cumin/queue.py
===================================================================
--- mgmt/cumin/python/cumin/queue.py	2007-11-20 21:24:45 UTC (rev 1346)
+++ mgmt/cumin/python/cumin/queue.py	2007-11-20 21:34:39 UTC (rev 1347)
@@ -120,34 +120,34 @@
         return queue.stats.consumers
 
     def render_messages_enqueued(self, session, queue):
-        value = queue.stats.msgTotalEnqueues
-        return fmt_rate(value, "msg", "sec")
+        stat = self.app.cmodel.queue.get_stat("msgTotalEnqueues")
+        return fmt_rate(stat.rate(queue), "msg", "sec")
 
     def render_messages_dequeued(self, session, queue):
-        value = queue.stats.msgTotalDequeues
-        return fmt_rate(value, "msg", "sec")
+        stat = self.app.cmodel.queue.get_stat("msgTotalDequeues")
+        return fmt_rate(stat.rate(queue), "msg", "sec")
 
     def render_message_depth(self, session, queue):
         return queue.stats.msgDepth
 
     def render_message_depth_accel(self, session, queue):
-        value = queue.stats.msgDepth
-        return fmt_rate(value, "msg", "sec")
+        stat = self.app.cmodel.queue.get_stat("msgDepth")
+        return fmt_rate(stat.rate(queue), "msg", "sec")
 
     def render_bytes_enqueued(self, session, queue):
-        value = queue.stats.byteTotalEnqueues
-        return fmt_rate(value, "byte", "sec")
+        stat = self.app.cmodel.queue.get_stat("byteTotalEnqueues")
+        return fmt_rate(stat.rate(queue), "byte", "sec")
 
     def render_bytes_dequeued(self, session, queue):
-        value = queue.stats.byteTotalDequeues
-        return fmt_rate(value, "byte", "sec")
+        stat = self.app.cmodel.queue.get_stat("byteTotalDequeues")
+        return fmt_rate(stat.rate(queue), "byte", "sec")
 
     def render_byte_depth(self, session, queue):
         return queue.stats.byteDepth
 
     def render_byte_depth_accel(self, session, queue):
-        value = queue.stats.byteDepth
-        return fmt_rate(value, "byte", "sec")
+        stat = self.app.cmodel.queue.get_stat("byteDepth")
+        return fmt_rate(stat.rate(queue), "byte", "sec")
 
 class QueueView(Widget):
     def __init__(self, app, name):