Fixed regression caused by a change to the qmf.console API.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@722167 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 8 deletions

diff --git a/qpid/python/commands/qpid-queue-stats b/qpid/python/commands/qpid-queue-stats
index 5aa32f9b38..3c727fddfd 100755
--- a/qpid/python/commands/qpid-queue-stats
+++ b/qpid/python/commands/qpid-queue-stats
@@ -29,7 +29,6 @@ from threading       import Condition
 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 @@ class BrokerManager(Console):
     self.filter = filter
 
   def objectProps(self, broker, record):
-    className = record.getClassKey()[1]
+    className = record.getClassKey().getClassName()
     if className != "queue":
       return
 
@@ -63,7 +62,7 @@ class BrokerManager(Console):
       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 @@ class BrokerManager(Console):
 
 
   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: