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

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2007-11-15 15:57:45 -0500 (Thu, 15 Nov 2007)
New Revision: 1321

Modified:
   mgmt/cumin/python/cumin/queue.py
   mgmt/cumin/python/cumin/queue.strings
   mgmt/cumin/python/cumin/widgets.strings
Log:
Adds a purge action to queue that currently just fires the echo method
on the managed broker.



Modified: mgmt/cumin/python/cumin/queue.py
===================================================================
--- mgmt/cumin/python/cumin/queue.py	2007-11-15 19:52:03 UTC (rev 1320)
+++ mgmt/cumin/python/cumin/queue.py	2007-11-15 20:57:45 UTC (rev 1321)
@@ -99,6 +99,12 @@
         self.add_mode(self.view)
         self.set_view_mode(self.view)
 
+        self.purge = QueuePurge(app, "purge")
+        self.add_mode(self.purge)
+
+    def show_purge(self, session):
+        return self.show_mode(session, self.purge)
+
     # XXX not awesome
     def get_object(self, session, object):
         queue = self.param.get(session)
@@ -188,6 +194,11 @@
     def render_updated(self, session, queue):
         return fmt_datetime(datetime.utcnow())
 
+    def render_purge_href(self, session, queue):
+        branch = session.branch()
+        self.parent().show_purge(branch)
+        return branch.marshal()
+
 class QueueBindingSet(ItemSet):
     def get_title(self, session, queue):
         return "Exchange Bindings %s" % fmt_count(len(queue.bindings))
@@ -332,6 +343,33 @@
     def render_cancel_content(self, session, queue):
         return "No, Cancel"
 
+def doit(error, args):
+    print error, args
+
+class QueuePurge(CuminConfirmForm):
+    def get_title(self, session, queue):
+        return "Purge Queue '%s'" % queue.name
+
+    def process_cancel(self, session, queue):
+        branch = session.branch()
+        self.page().show_queue(branch, queue).show_view(branch)
+        self.page().set_redirect_url(session, branch.marshal())
+
+    def process_submit(self, session, queue):
+        print "open purge"
+        
+        queue.mintVhost.mintBroker.echo(self.app.mint, doit, 1, "dude!")
+
+        print "close purge"
+
+        self.process_cancel(session, queue)
+
+    def render_submit_content(self, session, queue):
+        return "Yes, Purge Queue '%s'" % queue.name
+
+    def render_cancel_content(self, session, queue):
+        return "No, Cancel"
+
 class QueueBindingAdd(CuminForm):
     def __init__(self, app, name):
         super(QueueBindingAdd, self).__init__(app, name)

Modified: mgmt/cumin/python/cumin/queue.strings
===================================================================
--- mgmt/cumin/python/cumin/queue.strings	2007-11-15 19:52:03 UTC (rev 1320)
+++ mgmt/cumin/python/cumin/queue.strings	2007-11-15 20:57:45 UTC (rev 1321)
@@ -179,7 +179,7 @@
   <tr>
     <th class="actions" colspan="2">
       <h2>Act on This Queue:</h2>
-      <a href="{href}">Purge Messages</a>
+      <a href="{purge_href}">Purge Messages</a>
     </th>
   </tr>
 </table>

Modified: mgmt/cumin/python/cumin/widgets.strings
===================================================================
--- mgmt/cumin/python/cumin/widgets.strings	2007-11-15 19:52:03 UTC (rev 1320)
+++ mgmt/cumin/python/cumin/widgets.strings	2007-11-15 20:57:45 UTC (rev 1321)
@@ -4,7 +4,7 @@
     <h1>{title}</h1>
   </div>
   <div class="body">
-    <div>{confirm}</div>
+    <div>{submit}</div>
     <div>{cancel}</div>
     {hidden_inputs}
   </div>