diff --git a/SAS/QPIDInfrastructure/lib/QPIDDB.py b/SAS/QPIDInfrastructure/lib/QPIDDB.py index 46c6c3bc4d0b4e3a6ad4a5eb4307838c397f4969..bc48b7a1a08ecfbc8852b1154508b5430d02ff68 100755 --- a/SAS/QPIDInfrastructure/lib/QPIDDB.py +++ b/SAS/QPIDInfrastructure/lib/QPIDDB.py @@ -67,9 +67,9 @@ class qpidinfra: the example will return a full list of the federated queues. """ - ret=self.db.doquery("select h1.hostname as fromhost ,h2.hostname as tohost , queuename, exchangename from queueroutes JOIN hosts as h1 on (fromhost=h1.hostid) JOIN hosts as h2 on (tohost=h2.hostid) JOIN queues on (queueid=qid) JOIN exchanges on (exchangeid=eid);") - for item in ret: - callback(item) + ret=self.db.doquery("select h1.hostname as fromhost ,h2.hostname as tohost , queuename, exchangename from queueroutes JOIN hosts as h1 on (fromhost=h1.hostid) JOIN hosts as h2 on (tohost=h2.hostid) JOIN queues on (queueid=qid) JOIN exchanges on (exchangeid=eid);") + for item in ret: + callback(item) def perqpidbinding(self,callback): """ Iterate over all exchange->queue bindings defined in the database.