From 04f665efb098011baf4bbb66aff0b8e9cf325d4d Mon Sep 17 00:00:00 2001
From: Ted Ross <tross@apache.org>
Date: Thu, 23 Oct 2008 19:07:05 +0000
Subject: Marked old python management API as obsolete.  Updated 0-10 tests to
 use new qmfconsole API

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707449 13f79535-47bb-0310-9956-ffa450edef68
---
 python/tests_0-10/management.py | 31 ++++++++-----------------------
 1 file changed, 8 insertions(+), 23 deletions(-)

(limited to 'python/tests_0-10')

diff --git a/python/tests_0-10/management.py b/python/tests_0-10/management.py
index efec2b8a92..a47982173b 100644
--- a/python/tests_0-10/management.py
+++ b/python/tests_0-10/management.py
@@ -72,39 +72,25 @@ class ManagementTest (TestBase010):
             self.assertEqual (res.body,     body)
 
     def test_system_object (self):
-        session = self.session
- 
-        mc  = managementClient (session.spec)
-        mch = mc.addChannel (session)
-
-        mc.syncWaitForStable (mch)
-        systems = mc.syncGetObjects (mch, "system")
+        self.startQmf()
+        systems = self.qmf.getObjects(_class="system")
         self.assertEqual (len (systems), 1)
-        mc.removeChannel (mch)
 
     def test_self_session_id (self):
-        session = self.session
- 
-        mc  = managementClient (session.spec)
-        mch = mc.addChannel (session)
+        self.startQmf()
+        sessionId = self.qmf_broker.getSessionId()
+        brokerSessions = self.qmf.getObjects(_class="session")
 
-        info = mc.syncWaitForStable (mch)
-        brokerSessions = mc.syncGetObjects (mch, "session")
         found = False
         for bs in brokerSessions:
-            if bs.name == info.sessionId:
+            if bs.name == sessionId:
                 found = True
         self.assertEqual (found, True)
-        mc.removeChannel (mch)
 
     def test_standard_exchanges (self):
-        session = self.session
- 
-        mc  = managementClient (session.spec)
-        mch = mc.addChannel (session)
+        self.startQmf()
 
-        mc.syncWaitForStable (mch)
-        exchanges = mc.syncGetObjects (mch, "exchange")
+        exchanges = self.qmf.getObjects(_class="exchange")
         exchange = self.findExchange (exchanges, "")
         self.assertEqual (exchange.type, "direct")
         exchange = self.findExchange (exchanges, "amq.direct")
@@ -117,7 +103,6 @@ class ManagementTest (TestBase010):
         self.assertEqual (exchange.type, "headers")
         exchange = self.findExchange (exchanges, "qpid.management")
         self.assertEqual (exchange.type, "topic")
-        mc.removeChannel (mch)
 
     def findExchange (self, exchanges, name):
         for exchange in exchanges:
-- 
cgit v1.2.1