Author: tross
Date: Mon Dec 1 10:39:29 2008
New Revision: 722167
URL: http://svn.apache.org/viewvc?rev=722167&view=rev
Log:
Fixed regression caused by a change to the qmf.console API.
Modified:
incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats
Modified: incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats?rev=722167&r1=722166&r2=722167&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats (original)
+++ incubator/qpid/trunk/qpid/python/commands/qpid-queue-stats Mon Dec 1
10:39:29 2008
@@ -29,7 +29,6 @@
from qmf.console import Session, Console
from qpid.peer import Closed
from qpid.connection import Connection, ConnectionFailed
-from qpid.util import connect
from time import sleep
class BrokerManager(Console):
@@ -54,7 +53,7 @@
self.filter = filter
def objectProps(self, broker, record):
- className = record.getClassKey()[1]
+ className = record.getClassKey().getClassName()
if className != "queue":
return
@@ -63,7 +62,7 @@
self.objects[id] = (record.name, None, None)
def objectStats(self, broker, record):
- className = record.getClassKey()[1]
+ className = record.getClassKey().getClassName()
if className != "queue":
return
@@ -103,11 +102,7 @@
def Display (self):
- classes = self.session.getClasses("org.apache.qpid.broker")
- for cls in classes:
- if cls[1] == "queue":
- queueClassKey = cls
- self.session.bindClass(queueClassKey)
+ self.session.bindClass("org.apache.qpid.broker", "queue")
print "Queue Name Sec Depth
Enq Rate Deq Rate"
print
"========================================================================================"
try:
