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

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2008-04-17 13:16:10 -0400 (Thu, 17 Apr 2008)
New Revision: 1929

Modified:
   mgmt/cumin/python/cumin/queue.py
   mgmt/cumin/python/cumin/queue.strings
Log:
Add an enq/deq rate chart for transactional messages

Modified: mgmt/cumin/python/cumin/queue.py
===================================================================
--- mgmt/cumin/python/cumin/queue.py	2008-04-17 17:07:13 UTC (rev 1928)
+++ mgmt/cumin/python/cumin/queue.py	2008-04-17 17:16:10 UTC (rev 1929)
@@ -511,6 +511,9 @@
         chart = self.DequeueTransactionRateChart(app, "deqtxn")
         self.add_child(chart)
         
+        chart = self.EnqueueDequeueRateChart(app, "enqdeq")
+        self.add_child(chart)
+        
     def render_title(self, session):
         return "Transactions"
 
@@ -538,6 +541,17 @@
         def render_title(self, session, queue):
             return "Dequeue Transaction Operations per Second"
 
+    class EnqueueDequeueRateChart(StatValueChart):
+        def __init__(self, app, name):
+            super(QueueStatsTransactions.EnqueueDequeueRateChart,
+                  self).__init__(app, name)
+
+            self.stats = ("msgTxnEnqueues", "msgTxnDequeues")
+            self.mode = "rate"
+
+        def render_title(self, session, queue):
+            return "Transactional Messages Enqueued and Dequeued"
+
 class QueueConsumerSet(PaginatedItemSet):
     def get_args(self, session):
         return self.frame.get_args(session)

Modified: mgmt/cumin/python/cumin/queue.strings
===================================================================
--- mgmt/cumin/python/cumin/queue.strings	2008-04-17 17:07:13 UTC (rev 1928)
+++ mgmt/cumin/python/cumin/queue.strings	2008-04-17 17:16:10 UTC (rev 1929)
@@ -229,6 +229,7 @@
     <td class="twocol">
       {enqtxn}
       {deqtxn}
+      {enqdeq}
     </td>
   </tr>
 </table>