[rhmessaging-commits] rhmessaging commits: r4116 - in mgmt/newdata/cumin/python/cumin: messaging and 1 other directory.

[rhmessaging-commits at lists.jboss.org]

Author: eallen
Date: 2010-07-14 08:33:58 -0400 (Wed, 14 Jul 2010)
New Revision: 4116

Modified:
   mgmt/newdata/cumin/python/cumin/messaging/binding.py
   mgmt/newdata/cumin/python/cumin/widgets.py
Log:
Fix references to schemas

Modified: mgmt/newdata/cumin/python/cumin/messaging/binding.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/messaging/binding.py	2010-07-14 12:32:22 UTC (rev 4115)
+++ mgmt/newdata/cumin/python/cumin/messaging/binding.py	2010-07-14 12:33:58 UTC (rev 4116)
@@ -420,7 +420,7 @@
         exchange_string = self.exchange.get(session)
         if exchange_string:
             obj = self.form.object.get(session)
-            cls = self.app.rosemary.org_apache_qpid_broker.Exchange
+            cls = self.app.model.org_apache_qpid_broker.Exchange
             vhostid = obj._class._name == "Vhost" and obj._id or obj._vhostRef_id
             exchanges = cls.get_selection(session.cursor, name=exchange_string, _vhostRef_id=vhostid)
             if len(exchanges):

Modified: mgmt/newdata/cumin/python/cumin/widgets.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/widgets.py	2010-07-14 12:32:22 UTC (rev 4115)
+++ mgmt/newdata/cumin/python/cumin/widgets.py	2010-07-14 12:33:58 UTC (rev 4116)
@@ -1528,7 +1528,7 @@
 
 class QueueInput(BaseBindingInput):
     def do_get_items(self, session):
-        cls = self.app.rosemary.org_apache_qpid_broker.Queue
+        cls = self.app.model.org_apache_qpid_broker.Queue
         queue = self.form.object.get(session)
         vhostid = queue._vhostRef_id
         queues = cls.get_selection(session.cursor, _vhostRef_id=vhostid)
@@ -1536,7 +1536,7 @@
 
 class ExchangeInput(BaseBindingInput):
     def do_get_items(self, session):
-        cls = self.app.rosemary.org_apache_qpid_broker.Exchange
+        cls = self.app.model.org_apache_qpid_broker.Exchange
         obj = self.form.object.get(session)
         vhostid = obj._class._name == "Vhost" and obj._id or obj._vhostRef_id
         exchanges = cls.get_selection(session.cursor, _vhostRef_id=vhostid)