the example will return a full list of the federated queues.
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);")
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);")
foriteminret:
foriteminret:
callback(item)
callback(item)
defperqpidbinding(self,callback):
defperqpidbinding(self,callback):
""" Iterate over all exchange->queue bindings defined in the database.
""" Iterate over all exchange->queue bindings defined in the database.