Added property-selector to the console getObjects function

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

2 files changed, 23 insertions, 23 deletions

diff --git a/qpid/python/commands/qpid-config b/qpid/python/commands/qpid-config
index 0998c58bce..925b54b682 100755
--- a/qpid/python/commands/qpid-config
+++ b/qpid/python/commands/qpid-config
@@ -82,8 +82,8 @@ class BrokerManager:
         self.qmf.delBroker(self.broker)
 
     def Overview (self):
-        exchanges = self.qmf.getObjects(name="exchange")
-        queues    = self.qmf.getObjects(name="queue")
+        exchanges = self.qmf.getObjects(cls="exchange")
+        queues    = self.qmf.getObjects(cls="queue")
         print "Total Exchanges: %d" % len (exchanges)
         etype = {}
         for ex in exchanges:
@@ -104,7 +104,7 @@ class BrokerManager:
         print "    non-durable: %d" % (len (queues) - _durable)
 
     def ExchangeList (self, filter):
-        exchanges = self.qmf.getObjects(name="exchange")
+        exchanges = self.qmf.getObjects(cls="exchange")
         print "Durable   Type      Bindings  Exchange Name"
         print "======================================================="
         for ex in exchanges:
@@ -112,9 +112,9 @@ class BrokerManager:
                 print "%4c      %-10s%5d     %s" % (YN (ex.durable), ex.type, ex.bindingCount, ex.name)
 
     def ExchangeListRecurse (self, filter):
-        exchanges = self.qmf.getObjects(name="exchange")
-        bindings  = self.qmf.getObjects(name="binding")
-        queues    = self.qmf.getObjects(name="queue")
+        exchanges = self.qmf.getObjects(cls="exchange")
+        bindings  = self.qmf.getObjects(cls="binding")
+        queues    = self.qmf.getObjects(cls="queue")
         for ex in exchanges:
             if self.match (ex.name, filter):
                 print "Exchange '%s' (%s)" % (ex.name, ex.type)
@@ -128,8 +128,8 @@ class BrokerManager:
             
 
     def QueueList (self, filter):
-        queues   = self.qmf.getObjects(name="queue")
-        journals = self.qmf.getObjects(name="journal")
+        queues   = self.qmf.getObjects(cls="queue")
+        journals = self.qmf.getObjects(cls="journal")
         print "                                      Store Size"
         print "Durable  AutoDel  Excl  Bindings  (files x file pages)  Queue Name"
         print "==========================================================================================="
@@ -149,9 +149,9 @@ class BrokerManager:
                              YN (q.exclusive), q.bindingCount, q.name)
 
     def QueueListRecurse (self, filter):
-        exchanges = self.qmf.getObjects(name="exchange")
-        bindings  = self.qmf.getObjects(name="binding")
-        queues    = self.qmf.getObjects(name="queue")
+        exchanges = self.qmf.getObjects(cls="exchange")
+        bindings  = self.qmf.getObjects(cls="binding")
+        queues    = self.qmf.getObjects(cls="queue")
         for queue in queues:
             if self.match (queue.name, filter):
                 print "Queue '%s'" % queue.name
diff --git a/qpid/python/commands/qpid-route b/qpid/python/commands/qpid-route
index 8a9522e53a..f9f938cdec 100755
--- a/qpid/python/commands/qpid-route
+++ b/qpid/python/commands/qpid-route
@@ -62,7 +62,7 @@ class RouteManager:
         self.qmf.delBroker(self.broker)
 
     def getLink (self):
-        links = self.qmf.getObjects(name="link")
+        links = self.qmf.getObjects(cls="link")
         for link in links:
             if "%s:%d" % (link.host, link.port) == self.src.name ():
                 return link
@@ -74,7 +74,7 @@ class RouteManager:
             print "Linking broker to itself is not permitted"
             sys.exit(1)
 
-        brokers = self.qmf.getObjects(name="broker")
+        brokers = self.qmf.getObjects(cls="broker")
         broker = brokers[0]
         link = self.getLink()
         if link != None:
@@ -92,7 +92,7 @@ class RouteManager:
 
     def DelLink (self, srcBroker):
         self.src = qmfconsole.BrokerURL(srcBroker)
-        brokers = self.qmf.getObjects(name="broker")
+        brokers = self.qmf.getObjects(cls="broker")
         broker = brokers[0]
         link = self.getLink()
         if link == None:
@@ -103,7 +103,7 @@ class RouteManager:
             print "Close method returned:", res.status, res.text
 
     def ListLinks (self):
-        links = self.qmf.getObjects(name="link")
+        links = self.qmf.getObjects(cls="link")
         if len(links) == 0:
             print "No Links Found"
         else:
@@ -119,7 +119,7 @@ class RouteManager:
         if self.dest.name() == self.src.name():
             raise Exception("Linking broker to itself is not permitted")
 
-        brokers = self.qmf.getObjects(name="broker")
+        brokers = self.qmf.getObjects(cls="broker")
         broker = brokers[0]
 
         link = self.getLink()
@@ -140,7 +140,7 @@ class RouteManager:
         if link == None:
             raise Exception("Protocol Error - Missing link ID")
 
-        bridges = self.qmf.getObjects(name="bridge")
+        bridges = self.qmf.getObjects(cls="bridge")
         for bridge in bridges:
             if bridge.linkRef == link.getObjectId() and \
                     bridge.dest == exchange and bridge.key == routingKey:
@@ -164,7 +164,7 @@ class RouteManager:
                 raise Exception("No link found from %s to %s" % (self.src.name(), self.dest.name()))
             sys.exit (0)
 
-        bridges = self.qmf.getObjects(name="bridge")
+        bridges = self.qmf.getObjects(cls="bridge")
         for bridge in bridges:
             if bridge.linkRef == link.getObjectId() and bridge.dest == exchange and bridge.key == routingKey:
                 if _verbose:
@@ -186,8 +186,8 @@ class RouteManager:
             raise Exception("Route not found")
 
     def ListRoutes (self):
-        links   = self.qmf.getObjects(name="link")
-        bridges = self.qmf.getObjects(name="bridge")
+        links   = self.qmf.getObjects(cls="link")
+        bridges = self.qmf.getObjects(cls="bridge")
 
         for bridge in bridges:
             myLink = None
@@ -199,8 +199,8 @@ class RouteManager:
                 print "%s %s:%d %s %s" % (self.dest.name(), myLink.host, myLink.port, bridge.dest, bridge.key)
 
     def ClearAllRoutes (self):
-        links   = self.qmf.getObjects(name="link")
-        bridges = self.qmf.getObjects(name="bridge")
+        links   = self.qmf.getObjects(cls="link")
+        bridges = self.qmf.getObjects(cls="bridge")
 
         for bridge in bridges:
             if _verbose:
@@ -218,7 +218,7 @@ class RouteManager:
                 print "Ok"
 
         if _dellink:
-            links = self.qmf.getObjects(name="link")
+            links = self.qmf.getObjects(cls="link")
             for link in links:
                 if _verbose:
                     print "Deleting Link: %s:%d... " % (link.host, link.port),