diff options
| author | Ted Ross <tross@apache.org> | 2009-05-08 20:32:33 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2009-05-08 20:32:33 +0000 |
| commit | 5283aeedc1036a2d729f3d8075764c441d2e761d (patch) | |
| tree | 5d5cac22f9b0f1a68710d6cbe5da9037829a1013 | |
| parent | 3ae56e44a5b36fe1acb3fe3dc8b494c7022ab580 (diff) | |
| download | qpid-python-5283aeedc1036a2d729f3d8075764c441d2e761d.tar.gz | |
Optimize the qmf queries to only include the broker-embedded agents.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@773089 13f79535-47bb-0310-9956-ffa450edef68
| -rwxr-xr-x | python/commands/qpid-stat | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/python/commands/qpid-stat b/python/commands/qpid-stat index 1f1d247bb1..26860e5853 100755 --- a/python/commands/qpid-stat +++ b/python/commands/qpid-stat @@ -88,7 +88,13 @@ class IpAddr: class Broker(object): def __init__(self, qmf, broker): self.broker = broker - bobj = qmf.getObjects(_class="broker", _package="org.apache.qpid.broker", _broker=broker)[0] + + agents = qmf.getAgents() + for a in agents: + if a.getAgentBank() == 0: + self.brokerAgent = a + + bobj = qmf.getObjects(_class="broker", _package="org.apache.qpid.broker", _agent=self.brokerAgent)[0] self.currentTime = bobj.getTimestamps()[0] try: self.uptime = bobj.uptime @@ -100,21 +106,21 @@ class Broker(object): self.queues = {} package = "org.apache.qpid.broker" - list = qmf.getObjects(_class="connection", _package=package, _broker=broker) + list = qmf.getObjects(_class="connection", _package=package, _agent=self.brokerAgent) for conn in list: if pattern.match(conn.address): self.connections[conn.getObjectId()] = conn - list = qmf.getObjects(_class="session", _package=package, _broker=broker) + list = qmf.getObjects(_class="session", _package=package, _agent=self.brokerAgent) for sess in list: if sess.connectionRef in self.connections: self.sessions[sess.getObjectId()] = sess - list = qmf.getObjects(_class="exchange", _package=package, _broker=broker) + list = qmf.getObjects(_class="exchange", _package=package, _agent=self.brokerAgent) for exchange in list: self.exchanges[exchange.getObjectId()] = exchange - list = qmf.getObjects(_class="queue", _package=package, _broker=broker) + list = qmf.getObjects(_class="queue", _package=package, _agent=self.brokerAgent) for queue in list: self.queues[queue.getObjectId()] = queue |