You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2009/05/08 22:32:33 UTC
svn commit: r773089 - /qpid/trunk/qpid/python/commands/qpid-stat
Author: tross
Date: Fri May 8 20:32:33 2009
New Revision: 773089
URL: http://svn.apache.org/viewvc?rev=773089&view=rev
Log:
Optimize the qmf queries to only include the broker-embedded agents.
Modified:
qpid/trunk/qpid/python/commands/qpid-stat
Modified: qpid/trunk/qpid/python/commands/qpid-stat
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/commands/qpid-stat?rev=773089&r1=773088&r2=773089&view=diff
==============================================================================
--- qpid/trunk/qpid/python/commands/qpid-stat (original)
+++ qpid/trunk/qpid/python/commands/qpid-stat Fri May 8 20:32:33 2009
@@ -88,7 +88,13 @@
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 @@
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
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org