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)