[rhmessaging-commits] rhmessaging commits: r3987 - mgmt/newdata/cumin/python/cumin.

[rhmessaging-commits at lists.jboss.org]

Author: eallen
Date: 2010-05-25 12:44:22 -0400 (Tue, 25 May 2010)
New Revision: 3987

Modified:
   mgmt/newdata/cumin/python/cumin/objecttask.py
   mgmt/newdata/cumin/python/cumin/objecttask.strings
Log:
Display list of selected items in SelectionTaskForm

Modified: mgmt/newdata/cumin/python/cumin/objecttask.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/objecttask.py	2010-05-25 16:41:40 UTC (rev 3986)
+++ mgmt/newdata/cumin/python/cumin/objecttask.py	2010-05-25 16:44:22 UTC (rev 3987)
@@ -1,3 +1,6 @@
+from qpid.connection import *
+from qpid.util import *
+
 from rosemary.model import *
 from wooly.forms import *
 from wooly.resources import *
@@ -85,6 +88,26 @@
     def do_invoke(self, invoc, obj, *args):
         pass
 
+    def amqp_call(self, vhost, callback):
+        db_conn = self.app.database.get_connection()
+        cursor = db_conn.cursor()
+
+        cls = self.app.model.org_apache_qpid_broker.Broker
+        broker = cls.get_object_by_id(cursor, vhost._brokerRef_id)
+        port = broker.port
+
+        cls = self.app.model.org_apache_qpid_broker.System
+        system = cls.get_object_by_id(cursor, broker._systemRef_id)
+        host = system.nodeName
+
+        sock = connect(host, port)
+        conn = Connection(sock)
+        conn.start()
+        sess = conn.session()
+
+        callback(sess)
+        conn.close()
+
     def qmf_call(self, invoc, obj, meth, *args):
         def completion(status_code, output_args):
             invoc.status_code = status_code
@@ -92,8 +115,8 @@
 
             invoc.end()
 
-        agent = self.app.model.agents[obj._qmf_agent_id]
-        agent.call_method(completion, obj, meth, *args)
+        session = self.app.session
+        session.call_method(completion, obj, meth, args)
 
     def exception(self, invoc, e):
         now = datetime.now()
@@ -302,17 +325,20 @@
 
         self.selection = SessionAttribute(self, "selection")
 
+        self.content = self.SelectionList(app, "fields")
+        self.replace_child(self.content)
+
     def do_process(self, session):
         selection = list()
-        
+
         self.selection.set(session, selection)
 
         for id in self.ids.get(session):
-            item = self.cls.get_object(session.cursor, id)
+            item = self.cls.get_object_by_id(session.cursor, id)
             selection.append(item)
 
         super(SelectionTaskForm, self).do_process(session)
-    
+
     def process_submit(self, session):
         selection = self.selection.get(session)
 
@@ -322,6 +348,16 @@
     def render_title(self, session):
         return self.task.get_title(session)
 
+    class SelectionList(ItemSet):
+        def do_get_items(self, session):
+            return self.parent.selection.get(session)
+
+        def render_item_content(self, session, item):
+            return item.name
+
+        def render_item_class(self, session, item):
+            return "item"
+
 class ObjectTaskLink(Link):
     def __init__(self, app, name, task):
         assert isinstance(task, ObjectTask), task

Modified: mgmt/newdata/cumin/python/cumin/objecttask.strings
===================================================================
--- mgmt/newdata/cumin/python/cumin/objecttask.strings	2010-05-25 16:41:40 UTC (rev 3986)
+++ mgmt/newdata/cumin/python/cumin/objecttask.strings	2010-05-25 16:44:22 UTC (rev 3987)
@@ -7,3 +7,8 @@
     margin: 0.5em auto 1em auto;
     width: 80%;
 }
+
+[SelectionList.css]
+ul.SelectionList {
+    list-style: none;
+}