QPID-1291 - William Henry's python test (plus some test harness updates)

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

1 files changed, 8 insertions, 1 deletions

diff --git a/python/qpid/testlib.py b/python/qpid/testlib.py
index b5aa59f586..b8f4c29ceb 100644
--- a/python/qpid/testlib.py
+++ b/python/qpid/testlib.py
@@ -22,7 +22,7 @@
 #
 
 import sys, re, unittest, os, random, logging, traceback
-import qpid.client, qpid.spec
+import qpid.client, qpid.spec, qpid.qmfconsole
 import Queue
 from fnmatch import fnmatch
 from getopt import getopt, GetoptError
@@ -357,6 +357,11 @@ class TestBase010(unittest.TestCase):
                                username=testrunner.user, password=testrunner.password)
         self.conn.start(timeout=10)        
         self.session = self.conn.session("test-session", timeout=10)
+        self.qmf = None
+
+    def startQmf(self):
+        self.qmf = qpid.qmfconsole.Session()
+        self.qmf_broker = self.qmf.addBroker("%s:%d" % (testrunner.host, testrunner.port))
 
     def connect(self, host=None, port=None):
         spec = testrunner.spec
@@ -367,6 +372,8 @@ class TestBase010(unittest.TestCase):
     def tearDown(self):
         if not self.session.error(): self.session.close(timeout=10)
         self.conn.close(timeout=10)
+        if self.qmf:
+            self.qmf.delBroker(self.qmf_broker)
 
     def subscribe(self, session=None, **keys):
         session = session or self.session